バックグラウンドスレッドで使用すると非同期キューがハングアップする

Question

asyncio.Queueは同じスレッドでのみプッシュできますか？例えば：

import asyncio 
from threading import Thread 
import time 

q = asyncio.Queue() 

def produce(): 
    for i in range(100): 
     q.put_nowait(i) 
     time.sleep(0.1) 

async def consume(): 
    while True: 
     i = await q.get() 
     print('consumed', i) 

Thread(target=produce).start() 
asyncio.get_event_loop().run_until_complete(consume()) 

のみ

consumed 0 

を印刷した後ハング。私は何が欠けていますか？

Answer 1

call asyncio methods from another threadを直接入力することはできません。

どちらかloop.call_soon_threadsafeを使用します。

loop.call_soon_threadsafe(q.put_nowait, i) 

またはasyncio.run_coroutine_threadsafe：

future = asyncio.run_coroutine_threadsafe(q.put(i), loop) 

loopがあなたのメインスレッドにasyncio.get_event_loop()によって返されたループです。

Answer 2

janus ライブラリには、非同期イベントループ用と古典的なスレッドコード用の2つのフェイスが含まれています。

私はREADMEがライブラリをかなりよく説明していると信じています。