asyncio.gather
Функция asyncio.gather используется для одновременного выполнения нескольких заданий и сбора их результатов. Она принимает несколько корутин (или задач), создаёт для каждой из них задачу, и возвращает единую задачу, которая завершится, когда все переданные ей аргументы завершатся.
Пример:
import asyncio
async def task1():
await asyncio.sleep(1)
return "Результат задачи 1"
async def task2():
await asyncio.sleep(2)
return "Результат задачи 2"
async def main():
results = await asyncio.gather(task1(), task2())
print(results)
asyncio.run(main())
Поскольку каждая корутина в функции gather оборачивается в задачу,
выполнение каждой из корутины/задачи также начинается сразу и не блокирует выполнение основной программы
(до тех пор, пока не вызван await asyncio.gather(...)).
Если любая из подзадач выбрасывает исключение, оно будет передано вызывающему коду. Можно использовать параметр return_exceptions=True для возврата исключений как результатов.
Пример с обработкой исключений:
import asyncio
async def task1():
await asyncio.sleep(1)
return "Результат задачи 1"
async def task_with_exception():
await asyncio.sleep(2)
raise ValueError("Ошибка в задаче")
async def main():
results = await asyncio.gather(
task1(),
task_with_exception(),
return_exceptions=True
)
for result in results:
if isinstance(result, Exception):
print(f"Исключение: {result}")
else:
print(f"Результат: {result}")
asyncio.run(main())
По сути, asyncio.gather - это версия множества вызовов asyncio.create_task с дополнительной обработкой различных ситуаций. Однако, gather не позволяет вручную управлять каждой задачей.