Почему asyncio.gather() не запускает мои сопрограммы одновременно, если одна из них содержит функцию блокировки, и как пPython

Программы на Python
Ответить
Anonymous
 Почему asyncio.gather() не запускает мои сопрограммы одновременно, если одна из них содержит функцию блокировки, и как п

Сообщение Anonymous »

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

Код: Выделить всё

import asyncio
import time

async def task1():
print("task1 start")
time.sleep(2)  # intentionally blocking
print("task1 end")

async def task2():
print("task2 start")
await asyncio.sleep(1)
print("task2 end")

async def main():
await asyncio.gather(task1(), task2())

asyncio.run(main())
Я ожидал, что обе задачи будут выполняться одновременно, но задача 2 запускается только после завершения задачи 1. Почему asyncio.gather() не запускает их здесь одновременно? Как правильно сделать задачу 1 неблокирующей? Должен ли я заменить time.sleep() чем-то другим или запустить его в другом потоке?


Подробнее здесь: https://stackoverflow.com/questions/798 ... of-them-co
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «Python»