我正在使用asyncio在我的应用程序中进行消息处理。它接收消息,并确定将在ProcessPoolExecutor实例中运行的操作。一方面,concurrent.futures.ProcessPoolExecutor
的文档支持将iterable分块以在不同的工作进程上并行运行的思想。另一方面,loop.run_in_executor
将参数作为*args
传递,并且没有提到任何关于iterable处理的内容
我如何像concurrent.futures.ProcessPoolExecutor
的基本用法一样,将iterable传递给loop.run_in_executor
进行分块
目前没有回答
相关问题 更多 >
编程相关推荐