Три способа выполнить множество задач с asyncio
Функция для примера:
async def do_it(n):
await asyncio.sleep(random.uniform(0.5, 1))
return n
1. Последовательный вызов
async def main():
for i in range(100):
result = await do_it(i)
Такой вызов имеет смысл только тогда, когда результат одной задачи требуется для вызова следующей.
Если они независимы, то это антипаттерн, так как аналогичен простому синхронному вызову по очереди.
2. Упорядоченный результат
async def main():
tasks = [do_it(i) for i in range(100)]
results = await asyncio.gather(*tasks)
Выполняет корутины конкурентно и возвращает результат в виде списка.
Полезен когда требуется получить результаты в том же порядке в котором задачи отправлены.
3. Результат по мере готовности
tasks = [asyncio.create_task(do_it(i)) for i in range(100)]
for cor in asyncio.as_completed(tasks):
result = await cor
Так же выполняет корутины конкурентно, но не гарантирует порядок. Результат возвращается по мере готовности, каждый отдельно.
Полезен когда нужно обработать любой ответ как можно скорее.
#async
Today we present you: The takahē (Porphyrio hochstetteri)
— a flightless, endemic New Zealand bird, that was once thought extinct and famously rediscovered in 1948 — has been saved from the brink of extinction by intensive conservation: captive breeding, predator control, and protected reserves. Populations have increased but the species remains threatened and needs continued protection. Around 500 birds are now known to survive.
[Learn more here]
Tags: #Takahē#Conservation#NZ#Endangered#LazarusSpecies
🚩Желаю всем такого же прекрасного и раннего открытия зимнего сезона!
#heliboarding#methvenheliski#newzealand#snowboarding
#heliskiing#nz#хелиски#новаязеландия#сноубординг