- this.workerNodes.map(async workerNode => {
- this.flushTasksQueueByWorker(workerNode.worker)
+ this.workerNodes.map(async (workerNode, workerNodeKey) => {
+ this.flushTasksQueue(workerNodeKey)
*/
protected chooseWorkerNode (): [number, WorkerNode<Worker, Data>] {
let workerNodeKey: number
*/
protected chooseWorkerNode (): [number, WorkerNode<Worker, Data>] {
let workerNodeKey: number
const workerCreated = this.createAndSetupWorker()
this.registerWorkerMessageListener(workerCreated, message => {
if (
const workerCreated = this.createAndSetupWorker()
this.registerWorkerMessageListener(workerCreated, message => {
if (
- private enqueueTask (workerNodeKey: number, task: Task<Data>): void {
- this.workerNodes[workerNodeKey].tasksQueue.push(task)
+ private enqueueTask (workerNodeKey: number, task: Task<Data>): number {
+ return this.workerNodes[workerNodeKey].tasksQueue.push(task)
for (const task of this.workerNodes[workerNodeKey].tasksQueue) {
this.executeTask(workerNodeKey, task)
}
for (const task of this.workerNodes[workerNodeKey].tasksQueue) {
this.executeTask(workerNodeKey, task)
}