Interface TasksQueueOptions

Worker node tasks queue options.

interface TasksQueueOptions {
    concurrency?: number;
    size?: number;
    tasksFinishedTimeout?: number;
    tasksStealingOnBackPressure?: boolean;
    tasksStealingRatio?: number;
    taskStealing?: boolean;
}

Properties

concurrency?: number

Maximum number of tasks that can be executed concurrently on a worker node.

1
size?: number

Maximum tasks queue size per worker node flagging it as back pressured.

(pool maximum size)^2
tasksFinishedTimeout?: number

Queued tasks finished timeout in milliseconds at worker node termination.

2000
tasksStealingOnBackPressure?: boolean

Whether to enable tasks stealing under back pressure.

true
tasksStealingRatio?: number

Ratio of worker nodes that can steal tasks from another worker node.

0.6
taskStealing?: boolean

Whether to enable task stealing on idle.

true