TaskPool 模块设计文档

概述

TaskPool模块是异步任务管理组件，通过信号量机制控制任务并发数，支持自动任务生命周期管理。

初始化参数

参数名称	类型/必选	参数说明
max_concurrency	int (可选)	最大并发任务数，默认为4

类方法说明

create_task(coro_func, *args, **kwargs)

创建并启动异步任务。

参数

• coro_func: 需要执行的协程函数
• *args: 位置参数
• **kwargs: 关键字参数

返回值

• asyncio.Task: 已创建的任务对象

wait_all()

等待所有任务完成并返回结果列表。

返回值

• List[Any]: 任务执行结果列表