问题 我应该在一个程序中使用两个asyncio事件循环吗?


我想使用Python 3 asyncio 模块来创建服务器应用程序。 我使用主事件循环来监听网络,当收到新数据时,它会做一些计算并将结果发送给客户端。 “做一些计算”是否需要新的事件循环?或者它可以使用主事件循环?


6021
2017-12-04 09:39


起源

你在寻找像生产者消费模式这样的东西吗? en.wikipedia.org/wiki/Producer%E2%80%93consumer_problem - Andrew Scott Evans
在这种情况下,您可以将生产者用作主循环中的进程,并且只需要一个循环。这取决于网络使用计算机有很多网络端口。 - Andrew Scott Evans


答案:


您可以在主事件循环中执行计算工作,但在发生这种情况时将阻止整个事件循环 - 不能提供其他请求,并且将阻止您在事件循环中运行的任何其他操作。如果这是不可接受的,您可能希望使用单独的进程运行计算工作 BaseEventLoop.run_in_executor。这是一个非常简单的例子来证明它:

import time
import asyncio
from concurrent.futures import ProcessPoolExecutor

def cpu_bound_worker(x, y):
    print("in worker")
    time.sleep(3)
    return x +y

@asyncio.coroutine
def some_coroutine():
    yield from asyncio.sleep(1)
    print("done with coro")

@asyncio.coroutine
def main():
    loop = asyncio.get_event_loop()
    loop.set_default_executor(ProcessPoolExecutor())
    asyncio.async(some_coroutine())
    out = yield from loop.run_in_executor(None, cpu_bound_worker, 3, 4)
    print("got {}".format(out))

loop = asyncio.get_event_loop()
loop.run_until_complete(main())

输出:

in worker
done with coro
got 7

cpu_bound_worker 在子进程中执行,并且事件循环将等待结果,就像任何其他非阻塞I / O操作一样,因此它不会阻止其他协同程序运行。


10
2017-12-04 16:20