summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
6c9d700)
queuing enabled
Signed-off-by: Jérôme Benoit <jerome.benoit@sap.com>
id: crypto.randomUUID()
}
const res = this.internalExecute(workerNodeKey, workerNode, submittedTask)
id: crypto.randomUUID()
}
const res = this.internalExecute(workerNodeKey, workerNode, submittedTask)
- let currentTask: Task<Data> = submittedTask
if (
this.opts.enableTasksQueue === true &&
if (
this.opts.enableTasksQueue === true &&
- (this.busy || this.tasksQueueSize(workerNodeKey) > 0)
+ (this.busy || this.workerNodes[workerNodeKey].tasksUsage.running > 0)
- currentTask = this.enqueueDequeueTask(
- workerNodeKey,
- submittedTask
- ) as Task<Data>
+ this.enqueueTask(workerNodeKey, submittedTask)
+ } else {
+ this.sendToWorker(workerNode.worker, submittedTask)
- this.sendToWorker(workerNode.worker, currentTask)
this.checkAndEmitEvents()
// eslint-disable-next-line @typescript-eslint/return-await
return res
this.checkAndEmitEvents()
// eslint-disable-next-line @typescript-eslint/return-await
return res
this.workerChoiceStrategyContext.remove(workerNodeKey)
}
this.workerChoiceStrategyContext.remove(workerNodeKey)
}
- private enqueueDequeueTask (
- workerNodeKey: number,
- task: Task<Data>
- ): Task<Data> | undefined {
- this.enqueueTask(workerNodeKey, task)
- return this.dequeueTask(workerNodeKey)
- }
-
private enqueueTask (workerNodeKey: number, task: Task<Data>): void {
this.workerNodes[workerNodeKey].tasksQueue.push(task)
}
private enqueueTask (workerNodeKey: number, task: Task<Data>): void {
this.workerNodes[workerNodeKey].tasksQueue.push(task)
}