this.computeWorkerNodeVirtualTaskEndTimestamp(workerNodeKey)
}
}
- return (workerNode.strategyData.virtualTaskEndTimestamp as number) <
- ((workerNodes[minWorkerNodeKey].strategyData as StrategyData)
- .virtualTaskEndTimestamp as number)
+ return this.isWorkerNodeReady(workerNodeKey) &&
+ (workerNode.strategyData.virtualTaskEndTimestamp as number) <
+ ((workerNodes[minWorkerNodeKey].strategyData as StrategyData)
+ .virtualTaskEndTimestamp as number)
? workerNodeKey
: minWorkerNodeKey
},
private getWorkerNodeVirtualTaskStartTimestamp (
workerNodeKey: number
): number {
+ const virtualTaskEndTimestamp =
+ this.pool.workerNodes[workerNodeKey]?.strategyData
+ ?.virtualTaskEndTimestamp
const now = performance.now()
- return now <
- (this.pool.workerNodes[workerNodeKey]?.strategyData
- ?.virtualTaskEndTimestamp ?? -Infinity)
- ? (this.pool.workerNodes[workerNodeKey]?.strategyData
- ?.virtualTaskEndTimestamp as number)
+ return now < (virtualTaskEndTimestamp ?? -Infinity)
+ ? (virtualTaskEndTimestamp as number)
: now
}
}