async-plus 0.3.0

安全地并发运行协程

asyncio.gather()函数存在一个问题：当一个协程出现错误时，其余的协程仍然会独立运行。这可能会导致难以检测的问题。相反，async_plus.try_gather()确保在出现错误时取消所有任务

result1, result2 = await async_plus.try_gather(
    coroutine_func1(...),
    coroutine_func2(...),
)

一次性任务

使用create_task()时，你需要负责捕获异常。通常这会导致异常直到进程结束时才被看到，或者如果进程被杀死，可能根本看不到。使用launch_watched()，异常在抛出时立即记录。

async_plus.launch_watched(your_coroutine_func(...))

结构化任务组

async with async_plus.task_scope() as scope:
    scope.launch(coroutine_func1(...))
    scope.launch(coroutine_func2(...))
    await scope.wait()

默认情况下，wait()调用在所有任务完成或第一个异常发生时返回。在任何情况下，所有未完成的任务都在async with块结束时被取消。

在监督程序中增加尝试之间的延迟

retry_delayer = async_plus.RetryDelayer([0, 10, 60], random_shift=1)
while True:
    try:
        await run_service_x()
    # In Python <3.8 it inherits from Exception
    except asyncio.CancelledError:
        raise
    except Exception:
        logger.exception('Error in service X:')
        await retry_delayer.sleep()

记录长等待时间

你的程序挂起了，但你不知道它在等待什么？用impatient()包装可疑的协程来查看瓶颈

await async_plus.impatient(asyncio.sleep(10), log_after=5)

或者只记录它花费的时间

await async_plus.impatient(asyncio.sleep(10), log_completion='always')

变更日志

查看变更日志。