asynchrony

Python asyncio 框架，用于编写安全且快速的并发代码。

特性

• 类型注释和类型安全
• 易于处理取消、错误和调度。
• 经过良好测试和文档化。
• 无依赖。
• 基于实际经验和痛点。

安装和使用

python3 -m pip install asynchrony

一个简单的示例，用于启动所有URL的并发任务（同时最多100个任务）并等待它们全部完成

from asynchrony import Tasks

async def download_page(url: str) -> bytes:
    ...

urls = [...]
tasks = Tasks[bytes](timeout=10, max_concurrency=100)
tasks.map(urls, download_page)

try:
    pages = await tasks
except Exception:
    failed = sum(t.failed for t in tasks)
    print(f'{failed} tasks failed')
    cancelled = sum(t.cancelled for t in tasks)
    print(f'{cancelled} tasks cancelled')
else:
    print(f'finished {len(tasks)} tasks')

查看教程获取可运行的示例。