我有一个应用程序,它将协同器添加到已经运行的事件循环中。这些协同机制的参数依赖于I/O,在我最初使用loop.run_forever()启动事件循环时是不可用的,所以我稍后会添加任务。loop.run_forever()
while True: print("s")
#loop.create_tasktask created before thread created
我试图用stream编写一个并发流处理程序,我想知道这是否是Python协同最有效的使用。asyncio包有大量的选项,但是很难确定项目的正确方法,我认为这些文档在解释每个项目的优缺点方面做得并不好。
我认为这里不需要多个线程的开销,我需要异步循环之间的相互通信。我应该为我的每个函数创建一个单独的BaseEventLoop吗?作为Python,我认为这个问题(There should be one-
Python抱怨RuntimeWarning: coroutine 'Queue.put' was never awaited更新。我能够使用create_task将项放到队列中,但是它要么是阻塞在get上,要么是put,直到系统中发生了其他异步事件才停止阻塞,尽管现在队列中应该有一个项,这样它就不需要阻塞了。知道为什么会发生这种事吗?它需要大约10-20才能自动