Class TaskQueue

TaskQueue 任务队列管理

Hierarchy

TaskQueue

Constructors

constructor

new TaskQueue(config?: TaskQueueConfig): TaskQueue
Parameters
- Optional config: TaskQueueConfig
Returns TaskQueue
- Defined in src/taskQueue.ts:62

Properties

`Readonly` AllowedRetrySystemErrorCodes

AllowedRetrySystemErrorCodes: number[] = []

需要处理的系统错误当错误信息匹配的时候才会进入重试task流程否则任务不会重试即任务重试需要满足两个条件：报错+报错信息匹配 *

`Readonly` AllowedRetrySystemErrorMessages

AllowedRetrySystemErrorMessages: string[] = []

需要处理的系统错误当错误信息匹配的时候才会进入重试task流程否则任务不会重试即任务重试需要满足两个条件：报错+报错信息匹配 *

`Readonly` AllowedRetrySystemErrorNames

AllowedRetrySystemErrorNames: string[] = []

需要处理的系统错误当错误信息匹配的时候才会进入重试task流程否则任务不会重试即任务重试需要满足两个条件：报错+报错信息匹配 *

`Readonly` DelayRetryTime

DelayRetryTime: number = 1888

延迟重试时间单位：毫秒 *

`Readonly` ExecuteTaskTime

ExecuteTaskTime: number = 888

执行任务的单位时间 *

`Readonly` MaxExecuteTask

MaxExecuteTask: number = 8

最大可执行的任务数量 *

`Readonly` MaxKeepLiveSuccessTask

MaxKeepLiveSuccessTask: number = 0

最大保存的执行成功任务数量 *

`Readonly` MaxRetry

MaxRetry: number = 8

最大重试次数 *

`Readonly` emitter

emitter: Emitter<any> = ...

`Readonly` failTaskQueue

failTaskQueue: Map<string, Task> = ...

失败的任务队列 *

`Readonly` processingTaskQueue

processingTaskQueue: Map<string, Task> = ...

处理中的任务队列 *

`Readonly` readyTaskQueue

readyTaskQueue: Map<string, Task> = ...

已经准备好的任务队列 *

`Readonly` successTaskQueue

successTaskQueue: Map<string, Task> = ...

执行成功的任务队列 *

Methods

createTask

createTask(data: CreateTaskParams): Promise<any>
创建任务 *
Parameters
- data: CreateTaskParams
Returns Promise<any>
- Defined in src/taskQueue.ts:245

`Private` findPreConditionTaskChildTasks

findPreConditionTaskChildTasks(parentTaskId: string): Promise<Task[]>
Parameters
- parentTaskId: string
Returns Promise<Task[]>
- Defined in src/taskQueue.ts:193

`Private` getIdleTaskQuantity

getIdleTaskQuantity(): Promise<number>
处理队列空闲任务数量 *

Returns Promise<number>
- Defined in src/taskQueue.ts:228

`Private` getPreConditionTaskOnProcessing

getPreConditionTaskOnProcessing(): Promise<undefined | Task>
Returns Promise<undefined | Task>
- Defined in src/taskQueue.ts:188

`Private` getProcessingTaskQueueExecutableTasks

getProcessingTaskQueueExecutableTasks(): Promise<Task[]>
返回状态为ready的即将执行的任务(执行队列中) *

Returns Promise<Task[]>
- Defined in src/taskQueue.ts:137

`Private` getReadyTaskQueueByLevelSort

getReadyTaskQueueByLevelSort(): Promise<Task[]>
isPreCondition为true的情况下无视level规则直接排在普通任务前面 *

Returns Promise<Task[]>
- Defined in src/taskQueue.ts:181

`Private` getReadyTaskQueueExecutableTasks

getReadyTaskQueueExecutableTasks(): Promise<Task[]>
返回状态为ready的准备执行的任务(准备队列中) *

Returns Promise<Task[]>
- Defined in src/taskQueue.ts:199

`Private` init

init(): void
队列初始化 *

Returns void
- Defined in src/taskQueue.ts:88

`Private` startFailTaskQueue

startFailTaskQueue(task: Task): Promise<void>
开始处理失败的队列 *
Parameters
- task: Task
Returns Promise<void>
- Defined in src/taskQueue.ts:121

`Private` startProcessingTaskQueue

startProcessingTaskQueue(): Promise<void>
开始执行任务 *

Returns Promise<void>
- Defined in src/taskQueue.ts:143

`Private` startReadyTaskQueue

startReadyTaskQueue(): Promise<void>
开始处理准备阶段的任务队列 *

Returns Promise<void>
- Defined in src/taskQueue.ts:233

`Private` startSuccessTaskQueue

startSuccessTaskQueue(task: Task): Promise<void>
开始处理成功的队列 *
Parameters
- task: Task
Returns Promise<void>
- Defined in src/taskQueue.ts:110

Class TaskQueue

TaskQueue 任务队列管理

Hierarchy

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

Optional config: TaskQueueConfig

Returns TaskQueue

Properties

Readonly AllowedRetrySystemErrorCodes

Readonly AllowedRetrySystemErrorMessages

Readonly AllowedRetrySystemErrorNames

Readonly DelayRetryTime

Readonly ExecuteTaskTime

Readonly MaxExecuteTask

Readonly MaxKeepLiveSuccessTask

Readonly MaxRetry

Readonly emitter

Readonly failTaskQueue

Readonly processingTaskQueue

Readonly readyTaskQueue

Readonly successTaskQueue

Methods

createTask

Parameters

data: CreateTaskParams

Returns Promise<any>

Private findPreConditionTaskChildTasks

Parameters

parentTaskId: string

Returns Promise<Task[]>

Private getIdleTaskQuantity

Returns Promise<number>

Private getPreConditionTaskOnProcessing

Returns Promise<undefined | Task>

Private getProcessingTaskQueueExecutableTasks

Returns Promise<Task[]>

Private getReadyTaskQueueByLevelSort

Returns Promise<Task[]>

Private getReadyTaskQueueExecutableTasks

Returns Promise<Task[]>

Private init

Returns void

Private startFailTaskQueue

Parameters

task: Task

Returns Promise<void>

Private startProcessingTaskQueue

Returns Promise<void>

Private startReadyTaskQueue

Returns Promise<void>

Private startSuccessTaskQueue

Parameters

task: Task

Returns Promise<void>

Settings

Member Visibility

Theme

`Optional` config: TaskQueueConfig

`Readonly` AllowedRetrySystemErrorCodes

`Readonly` AllowedRetrySystemErrorMessages

`Readonly` AllowedRetrySystemErrorNames

`Readonly` DelayRetryTime

`Readonly` ExecuteTaskTime

`Readonly` MaxExecuteTask

`Readonly` MaxKeepLiveSuccessTask

`Readonly` MaxRetry

`Readonly` emitter

`Readonly` failTaskQueue

`Readonly` processingTaskQueue

`Readonly` readyTaskQueue

`Readonly` successTaskQueue

`Private` findPreConditionTaskChildTasks

`Private` getIdleTaskQuantity

`Private` getPreConditionTaskOnProcessing

`Private` getProcessingTaskQueueExecutableTasks

`Private` getReadyTaskQueueByLevelSort

`Private` getReadyTaskQueueExecutableTasks

`Private` init

`Private` startFailTaskQueue

`Private` startProcessingTaskQueue

`Private` startReadyTaskQueue

`Private` startSuccessTaskQueue