if (executeTask) {
this.executeTask(
targetWorkerNodeKey,
- this.popTask(workerNodeKey) as Task<Data>
+ this.dequeueTask(workerNodeKey) as Task<Data>
)
} else {
this.enqueueTask(
targetWorkerNodeKey,
- this.popTask(workerNodeKey) as Task<Data>
+ this.dequeueTask(workerNodeKey) as Task<Data>
)
}
}
return this.workerNodes[workerNodeKey].dequeueTask()
}
- private popTask (workerNodeKey: number): Task<Data> | undefined {
- return this.workerNodes[workerNodeKey].popTask()
- }
-
private tasksQueueSize (workerNodeKey: number): number {
return this.workerNodes[workerNodeKey].tasksQueueSize()
}