时间戳

首页 > 解决方案 > 使用 concurrent.futures.ProcessPoolExecutor 作为 loop.run_in_executor() 的执行程序的异步可迭代处理

python - 使用 concurrent.futures.ProcessPoolExecutor 作为 loop.run_in_executor() 的执行程序的异步可迭代处理

问题描述

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

如何loop.run_in_executor像基本concurrent.futures.ProcessPoolExecutor用法一样将可迭代传递给分块？

标签： pythonpython-asyncio

解决方案

推荐阅读