...{
size: Math.pow(this.maxSize, 2),
concurrency: 1,
- tasksStealing: true,
+ taskStealing: true,
tasksStealingOnBackPressure: true
},
...tasksQueueOptions
// Send the statistics message to worker.
this.sendStatisticsMessageToWorker(workerNodeKey)
if (this.opts.enableTasksQueue === true) {
- if (this.opts.tasksQueueOptions?.tasksStealing === true) {
+ if (this.opts.tasksQueueOptions?.taskStealing === true) {
this.workerNodes[workerNodeKey].onEmptyQueue =
this.taskStealingOnEmptyQueue.bind(this)
}