在 Thread 中使用 asyncio 的问题

如下使用asyncio没有问题。

import asyncio


async def main():
    await asyncio.sleep(1)
    aaa = 1
    print (aaa)


loop = asyncio.get_event_loop()
loop.run_until_complete(main())
loop.close()

但是，我必须在 Thread 中使用 asyncio，如下面的简单代码所示，这会导致错误如下

import asyncio
import threading

async def main():
    await asyncio.sleep(1)
    aaa = 1
    print (aaa)


def test():
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())
    loop.close()


t=threading.Thread(target=test)
t.start()

错误消息（运行时错误：线程“Thread-1”中没有当前事件循环。）

Exception in thread Thread-1:
Traceback (most recent call last):
  File "D:\Anaconda3\Lib\threading.py", line 932, in _bootstrap_inner
    self.run()
  File "D:\Anaconda3\Lib\threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  File "D:/Test/Test4/main.py", line 57, in test
    loop = asyncio.get_event_loop()
  File "D:\Anaconda3\Lib\asyncio\events.py", line 639, in get_event_loop
    raise RuntimeError('There is no current event loop in thread %r.'
RuntimeError: There is no current event loop in thread 'Thread-1'.

如何在线程中使用 asyncio？

这对我来说非常重要。 我已经为这个问题苦苦挣扎了两天。

我将不胜感激你的帮助。

除非您需要使用预先存在的事件循环（此处不是这种情况）或支持 Python 3.6，use asyncio.run https://docs.python.org/3/library/asyncio-task.html#asyncio.run而不是手动处理循环：

def test():
    asyncio.run(main())

这始终确保存在有效的事件循环，并且还处理正确的清理。

该函数总是创建一个新的事件循环并在最后关闭它。它应该用作 asyncio 程序的主要入口点，并且最好只被调用一次。

组合时请注意asyncio对于线程，事件循环通常应该在主循环中运行（参见例如业务流程外包#34697 https://bugs.python.org/issue34679）。而不是生成一个线程asyncio，更喜欢为程序的同步部分生成一个。

# launch synchronous work in child threads
t=threading.Thread(target=my_sync_tasks)
t.start()

# launch asynchronous work in main thread
asyncio.run(main())
t.join()