AsynciowithProcessPoolExecutorshutdownbeforefinishingalltasks
创始人
2024-09-21 07:00:53
0

在使用ProcessPoolExecutor的同时使用asyncio时,容易出现task未执行完毕便调用ProcessPoolExecutor的shutdown导致程序意外退出的问题。

解决方法是使用asyncio的asyncio.wait方法,等待所有task执行完毕后再调用ProcessPoolExecutor的shutdown。代码示例如下:

import asyncio
import concurrent.futures

async def run_in_executor(executor):
    return await asyncio.get_event_loop().run_in_executor(executor, some_blocking_io)

async def main():
    loop = asyncio.get_event_loop()
    executor = concurrent.futures.ProcessPoolExecutor()
    tasks = [loop.create_task(run_in_executor(executor)) for _ in range(5)]

    await asyncio.wait(tasks)
    executor.shutdown(wait=True)

if __name__ == '__main__':
    asyncio.run(main())

相关内容

热门资讯

透视安卓版(wepoke辅助有... 透视安卓版(wepoke辅助有挂)wepoke app(详细辅助爆料教程)从前有挂1、这是跨平台的w...
透视有挂(智星德州菠萝外挂)约... 透视有挂(智星德州菠萝外挂)约局吧是正规的吗(详细辅助安装教程)一贯有挂您好,智星德州菠萝外挂,确实...
德州ai人工智能!wpk机器人... 德州ai人工智能!wpk机器人,(WepokE)从前存在有挂(详细透视切实教程)准备好在德州ai人工...
透视总结(aapoker透明挂... 透视总结(aapoker透明挂)wepoke辅助器真的有用吗(详细辅助揭秘教程)竟然是真的有挂;是一...
wpk透明挂!德扑牌型胜率,(... 自定义wpk透明挂系统规律,只需要输入自己想要的开挂功能,一键便可以生成出微扑克专用辅助器,不管你是...
透视好友房(wpk辅助挂)wp... 透视好友房(wpk辅助挂)wpk线上德州俱乐部(详细辅助科技教程)本来真的是有挂;人气非常高,ai更...
wpk有辅助挂!wpk发牌规律... 自定义wpk有辅助挂系统规律,只需要输入自己想要的开挂功能,一键便可以生成出微扑克专用辅助器,不管你...
透视挂透视(wpk有辅助挂)f... 透视挂透视(wpk有辅助挂)fish poker外挂(详细辅助必备教程)真是真的是有挂1、超多福利:...
wepoke ai辅助!德扑之... wepoke ai辅助!德扑之星玩的是啥,(AApoker)竟然真的有挂(详细辅助扑克教程);支持多...
透视辅助(aapoker透明挂... 透视辅助(aapoker透明挂)红龙扑克机制(详细辅助普及教程)原本真的是有挂是一款可以让一直输的玩...