我正在尝试创建两个线程,每个线程都有自己的异步事件循环。我已经尝试了以下代码,但似乎不起作用:import asynciofrom threading import Threaddef hello(thread_name): print('hello from thread {}!'.format(thread_name))event_loop_a = asyncio.new_event_loop()event_loop_b = asyncio.new_event_loop()def callback_a(): asyncio.set_event_loop(event_loop_a) asyncio.get_event_loop().call_soon_threadsafe(lambda: hello('a'))def callback_b(): asyncio.set_event_loop(event_loop_b) asyncio.get_event_loop().call_soon_threadsafe(lambda: hello('b'))thread_a = Thread(target=callback_a, daemon=True)thread_b = Thread(target=callback_b, daemon=True)thread_a.start()thread_b.start()我的用例是调用 Tornado Web 框架的 websocket_connect 异步函数。
添加回答
举报
0/150
提交
取消