python - RuntimeError : There is no current event loop in thread 'Thread-1' , 多线程和异步错误

Question

我有一个调用异步循环的线程，但这会导致上述异常:

RuntimeError: There is no current event loop in thread 'Thread-1'.

本题:RuntimeError: There is no current event loop in thread in async + apscheduler遇到了同样的问题，但是他们提到了我没有的调度程序。

我的代码如下:

def worker(ws):
      l1 = asyncio.get_event_loop()
      l1.run_until_complete(ws.start())  


      l2 = asyncio.get_event_loop()
      l2.run_forever()


if __name__ == '__main__':
    ws = Server()
    p = threading.Thread(target=worker,args=(ws,))
    p.start()


    while True:
        try:
            #...do sth
        except KeyboardInterrupt:
            p.join()
            exit() 

Answer 1

新线程没有事件循环，所以你必须明确地传递和设置它:

def worker(ws, loop):
    asyncio.set_event_loop(loop)
    loop.run_until_complete(ws.start())

if __name__ == '__main__':
    ws = Server()
    loop = asyncio.new_event_loop()
    p = threading.Thread(target=worker, args=(ws, loop,))
    p.start()

此外，p.join() 不会正确终止您的脚本，因为您永远不会停止服务器，所以您的循环将继续运行，可能会挂断线程。在加入线程之前，您应该像 loop.call_soon_threadsafe(ws.shutdown) 那样调用 smth，最好是等待服务器正常关闭。