Три способа выполнить множество задач с 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
#vps#YxVM
vps商家:YxVM群组
抽奖地址:
【闪抽】YXVM 新加坡4837 三网优化 带宽扩容限时活动 109台1年免费使用权
🎁109台机器,年付使用权
活动机型配置
Singapore Hybrid Beta Basic
768MB RAM
1 VCPU
5GB DISK
384G ( SUM (IN+OUT) )
10Gbps Port
Basic DDoS Protection
Traffic to China Mainland will be shared with a dedicated 500Mbps Port.
⚠️参与抽奖的论坛账号需达到2级
开始时间:2025年03月27日20:30
结束时间:2025年03月27日20:35