this.checkValidTasksQueueOptions(tasksQueueOptions)
this.opts.tasksQueueOptions =
this.buildTasksQueueOptions(tasksQueueOptions)
- this.setTasksQueueMaxSize(this.opts.tasksQueueOptions.size as number)
+ this.setTasksQueueSize(this.opts.tasksQueueOptions.size as number)
} else if (this.opts.tasksQueueOptions != null) {
delete this.opts.tasksQueueOptions
}
}
- private setTasksQueueMaxSize (size: number): void {
+ private setTasksQueueSize (size: number): void {
for (const workerNode of this.workerNodes) {
workerNode.tasksQueueBackPressureSize = size
}
* @virtual
*/
protected setupHook (): void {
- /** Intentionally empty */
+ /* Intentionally empty */
}
/**
private updateTaskStolenStatisticsWorkerUsage (
workerNodeKey: number,
- workerNode: IWorkerNode<Worker, Data>,
taskName: string
): void {
+ const workerNode = this.workerNodes[workerNodeKey]
if (workerNode?.usage != null) {
++workerNode.usage.tasks.stolen
}
}
this.updateTaskStolenStatisticsWorkerUsage(
destinationWorkerNodeKey,
- destinationWorkerNode,
task.name as string
)
break
}
this.updateTaskStolenStatisticsWorkerUsage(
workerNodeKey,
- workerNode,
task.name as string
)
}