asyncio Queue.get delay - PullRequest
Новая
       15

asyncio Queue.get delay

0 голосов
/ 07 декабря 2018

У меня есть следующий код: 

import asyncio
import threading
import time

q = asyncio.Queue()

async def ping():
    while True:
        await asyncio.sleep(10)
        print("ping")

async def rcv():
    while True:
        item = await q.get()
        print("got item")

async def run():
    tasks = [asyncio.ensure_future(ping()), asyncio.ensure_future(rcv())]
    await asyncio.wait(tasks, return_when="FIRST_EXCEPTION")

loop = asyncio.get_event_loop()

def run_loop():
    asyncio.set_event_loop(loop)
    loop.run_until_complete(run())

threading.Thread(target=run_loop).start()

while True:
    time.sleep(2)
    q.put_nowait("item")
    print("item added")

Я ожидал, что каждые 2 секунды (каждый раз, когда элемент добавляется в очередь), я буду видеть вывод: 

item added
sleeping 2 seconds
got item

и каждые 10 секунд я также вижу ping.

Однако, это вывод, который я получаю (повторяя): 

sleeping 2 seconds
item added
sleeping 2 seconds
item added
sleeping 2 seconds
item added
sleeping 2 seconds
item added
sleeping 2 seconds
got item
got item
got item
got item
ping
item added
sleeping 2 seconds
...

Кажется, что часть item = await q.get()также дождитесь asyncio.sleep(10) от функции ping.

Что я пропустил?и как я могу исправить код, чтобы я получил ожидаемый результат?

Спасибо!

1 Ответ

0 голосов
/ 07 декабря 2018

Что я пропустил?и как я могу исправить код, чтобы получить ожидаемый результат?

Поскольку вы запускаете цикл обработки событий в отдельном потоке, вам нужно изменить q.put_nowait("item") на: 

loop.call_soon_threadsafe(q.put_nowait, "item")

Причина в том, что асинхронный код (намеренно) не является поточно-ориентированным, поэтому использование put_nowait не уведомляет цикл обработки событий о том, что новый элемент был поставлен в очередь.

...