使用concurrent.futures.ProcessPoolExecutor作为循环的执行器进行异步iterable处理。在执行器()中运行

2024-03-28 22:18:49 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在使用asyncio在我的应用程序中进行消息处理。它接收消息,并确定将在ProcessPoolExecutor实例中运行的操作。一方面,concurrent.futures.ProcessPoolExecutor的文档支持将iterable分块以在不同的工作进程上并行运行的思想。另一方面,loop.run_in_executor将参数作为*args传递,并且没有提到任何关于iterable处理的内容

我如何像concurrent.futures.ProcessPoolExecutor的基本用法一样,将iterable传递给loop.run_in_executor进行分块


Tags: 实例runin文档loopasyncio应用程序消息