Функция asyncio.wait() это еще один способ вызвать множество асинхронных задач.
Она работает в нескольких режимах.
1. Самый простой - ждем завершения всех задач
async def main():
tasks = [asyncio.create_task(do_it(i)) for i in range(10)]
done, pending = await asyncio.wait(
tasks,
return_when=asyncio.ALL_COMPLETED
)
for task in done:
try:
print(task.result())
except Exception as e:
print(e)
Очень похоже на gather, но работает не так.
▫️возвращает не результаты, а два сета с объектами Task у которых можно забрать результат через task.result() если они в списке done
▫️не гарантирует порядок результатов так как оба объекта это set
▫️не выбрасывает исключение когда оно появляется, а сохраняет его в Task. Исключение появится когда попробуете забрать резултьтат.
2. Ждем завершения первой задачи, даже если там ошибка.
async def main():
tasks = [asyncio.create_task(do_it(i)) for i in range(3)]
done, pending = await asyncio.wait(
tasks,
return_when=asyncio.FIRST_COMPLETED
)
# в done может быть несколько задач!
for task in done:
try:
print(task.result())
except Exception as e:
print(f"Fail: {e}")
# Оставшиеся задачи в pending, как правило, нужно отменить, иначе они будут продолжать работать
for task in pending:
task.cancel()
В сете done будут таски которые успели завершится, причем как успешно так и нет.
3. До первой ошибки.
Тоже самое, но с аргументом FIRST_EXCEPTION
done, pending = await asyncio.wait(
tasks,
return_when=asyncio.FIRST_EXCEPTION
)
Функция завершается как только первая задача упадет с ошибкой.
Учтите, что в любом случае done вы можете обранужить несколько задач, как с ошибками так и успешные.
↗️ Полный листинг примеров здесь
#async
После резни алавитов и друзов начался погром против сирийских христиан. Исламисты из соседних деревень начали нападать на христианские предприятия и дома в Аль-Сукейлабии (Сирия). То, что произошло сегодня, не будет последним разом. К сожалению, это будет повторяться снова и снова, потому что те, кто хочет уничтожить меньшинства, чувствуют себя воодушевлёнными, терпимыми и даже поощряемыми.
Молитесь за сирийских христиан, но не останавливайтесь на этом. Говорите об этом. Делитесь этим. Молчание мира — часть трагедии!!! 🙏🏼#syria
At least 1,383 civilians, mostly Alawites and Christians, were killed in a wave of violence that swept across Syria's Mediterranean coast — the Syrian Observatory for Human Rights
#Syria
Nieuwe gouverneur van Damascus verdedigt Israëlische aanvallen op Syrië
"Het is begrijpelijk dat Israël zich zorgen maakt als er een nieuwe regering aan de macht komt in Syrië."
"Misschien was Israël bang en daarom gingen ze door met een beetje bombarderen."
"We zijn niet bang voor Israël en we hebben geen probleem met Israël. We willen ons niet bemoeien met iets dat de veiligheid van Israël bedreigt."
#Syria
🇸🇾#Syria: Clashes broke out overnight between the Syrian Army (HTS) and alleged Uzbek jihadist militants in the Idlib countryside, around the villages of Al Foua, Kafraya, and Binnish.
Reportedly, the clashes occurred after several days of protests following the arrest of several Uzbek fighters.
(via @KurdishFrontNews)
🇸🇾#Syria: Protests erupted overnight in the city of Qamishli in al-Hasakah Governorate after a man, allegedly from the Rashid tribe, reportedly shot at the Kurdish flag and toward a security checkpoint at the entrance to the city.
(via @Intel_Rojava)