Asyncio 放入 queue.Queue

Question

一个非常简单的问题，我无法找到答案：

如果我想在自己的线程中运行 asyncio 事件循环，并将消息发送回主线程，它可以使用 queue.Queue 实例吗？

如果这确实可行且安全，是否有更好的方法将消息从非主线程中的异步循环传递到主线程？

这是一个玩具示例，似乎可行：

import asyncio
from queue import Queue
import threading

queue_to_main = Queue()


async def coro1():

    for i in range(5):
        queue_to_main.put_nowait(i)
        await asyncio.sleep(1)

    queue_to_main.put_nowait("STOP")


def runloop():
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    try:
        loop.run_until_complete(coro1())
    finally:
        loop.close()


t1 = threading.Thread(target=runloop)
t1.start()

while True:
    item = queue_to_main.get()
    if item == "STOP":
        break
    print(item)

t1.join()

我设想的场景是在它自己的线程中运行一个 aiohttp 服务器，但由于某些请求而让其与主线程通信。

Answer 1

asyncio.Queue 旨在用于单个事件循环内。 队列不是环间通信原语。

此外，您不应启动多个并行循环，每个循环都在自己的线程中。它是反模式（至少对于 Python 而言）。