tasksQueueOptions: {
concurrency: 2,
size: 4,
- tasksStealing: true,
+ taskStealing: true,
tasksStealingOnBackPressure: true
},
workerChoiceStrategy: WorkerChoiceStrategies.LEAST_USED,
expect(pool.opts.tasksQueueOptions).toStrictEqual({
concurrency: 1,
size: 4,
- tasksStealing: true,
+ taskStealing: true,
tasksStealingOnBackPressure: true
})
pool.enableTasksQueue(true, { concurrency: 2 })
expect(pool.opts.tasksQueueOptions).toStrictEqual({
concurrency: 2,
size: 4,
- tasksStealing: true,
+ taskStealing: true,
tasksStealingOnBackPressure: true
})
pool.enableTasksQueue(false)
expect(pool.opts.tasksQueueOptions).toStrictEqual({
concurrency: 1,
size: 4,
- tasksStealing: true,
+ taskStealing: true,
tasksStealingOnBackPressure: true
})
pool.setTasksQueueOptions({ concurrency: 2 })
expect(pool.opts.tasksQueueOptions).toStrictEqual({
concurrency: 2,
size: 4,
- tasksStealing: true,
+ taskStealing: true,
tasksStealingOnBackPressure: true
})
expect(() =>