- const workerVirtualTaskEndTimestamp =
- workerVirtualTaskStartTimestamp +
- (this.pool.getWorkerAverageTasksRunTime(worker) ?? 0)
- this.workerLastVirtualTaskTimestamp.set(worker, {
- start: workerVirtualTaskStartTimestamp,
- end: workerVirtualTaskEndTimestamp
- })
- }
+ }
+
+ private getWorkerVirtualTaskEndTimestamp (
+ workerNodeKey: number,
+ workerVirtualTaskStartTimestamp: number
+ ): number {
+ const workerTaskRunTime =
+ this.opts.measurement === Measurements.elu
+ ? this.getWorkerTaskElu(workerNodeKey)
+ : this.getWorkerTaskRunTime(workerNodeKey)
+ return workerVirtualTaskStartTimestamp + workerTaskRunTime
+ }
+
+ private getWorkerVirtualTaskStartTimestamp (workerNodeKey: number): number {
+ return Math.max(
+ performance.now(),
+ this.workersVirtualTaskEndTimestamp[workerNodeKey] ?? -Infinity
+ )