AsyncQueueExecutor
Defined in: async/AsyncQueueExecutor.ts:38
异步任务执行器 支持并发控制和动态任务调度
Constructors
Constructor
new AsyncQueueExecutor(maxConcurrent?): AsyncQueueExecutor;
Defined in: async/AsyncQueueExecutor.ts:44
Parameters
| Parameter | Type | Default value |
|---|---|---|
maxConcurrent | number | 3 |
Returns
AsyncQueueExecutor
Methods
addTask()
addTask<T>(task, id?): Promise<T>;
Defined in: async/AsyncQueueExecutor.ts:54
添加任务到执行器
Type Parameters
| Type Parameter |
|---|
T |
Parameters
| Parameter | Type | Description |
|---|---|---|
task | () => Promise<T> | 返回 Promise 的异步任务函数 |
id? | string | number | 任务唯一标识符（可选），用于去重相同任务 |
Returns
Promise<T>
返回任务执行结果的 Promise
clearQueue()
clearQueue(): void;
Defined in: async/AsyncQueueExecutor.ts:98
清空队列（不影响正在执行的任务）
Returns
void
getQueuedCount()
getQueuedCount(): number;
Defined in: async/AsyncQueueExecutor.ts:133
获取队列中等待的任务数
Returns
number
getRunningCount()
getRunningCount(): number;
Defined in: async/AsyncQueueExecutor.ts:126
获取当前运行中的任务数
Returns
number
getStatus()
getStatus(): ExecutorStatus;
Defined in: async/AsyncQueueExecutor.ts:75
获取当前状态
Returns
ExecutorStatus
包含运行中任务数、队列长度和最大并发数
setMaxConcurrent()
setMaxConcurrent(newMax): void;
Defined in: async/AsyncQueueExecutor.ts:87
动态修改最大并发数
Parameters
| Parameter | Type | Description |
|---|---|---|
newMax | number | 新的最大并发数 |
Returns
void
waitForAll()
waitForAll(): Promise<void>;
Defined in: async/AsyncQueueExecutor.ts:110
等待所有任务完成
Returns
Promise<void>
当所有任务完成时 resolve