Три способа выполнить множество задач с 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
🕵️#MEGA Bubblemaps: MEGA tokens were distributed among 8,360 addresses, with approximately 50% of addresses still holding all the tokens. About 40% of addresses have sold them completely, and around 10% of addresses have sold only a portion of the coins. link
Guillaume Faye left us on March 6, 2019, at the age of 69. He was a unique figure who leaves behind an extensive body of work. Like the ancient Greek heroes of old, he will achieve immortality if we continue to share his ideas. Guillaume laid the foundations—now it is up to us, dear comrades, to build the sanctuary of European civilization!
#MEGA
¿Que puede hacer este bot?
@MegaUploadXbot
Este bot cargará archivos y vinculará directamente a su cuenta de Mega entre otras características.
Idioma: inglés
(Visto en @botsgram_cu)
#mega