X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2Fabstract-worker.ts;h=a84bb0691fc588d3a8e51b0fe1696d7c85bb7dc9;hb=8a11bce46f69f1183d025572345755d4fd40231b;hp=76a7ee70ba96a93e6a92934a6b9cc54d81dbe821;hpb=4f487526a63c873d168386250b40ad8103c5a4d8;p=poolifier.git diff --git a/src/worker/abstract-worker.ts b/src/worker/abstract-worker.ts index 76a7ee70..a84bb069 100644 --- a/src/worker/abstract-worker.ts +++ b/src/worker/abstract-worker.ts @@ -224,7 +224,7 @@ export abstract class AbstractWorker< message: MessageValue ): void { try { - let taskPerformance = this.beginTaskPerformance(message) + let taskPerformance = this.beginTaskPerformance() const res = fn(message.data) taskPerformance = this.endTaskPerformance(taskPerformance) this.sendToMainWorker({ @@ -256,7 +256,7 @@ export abstract class AbstractWorker< fn: WorkerAsyncFunction, message: MessageValue ): void { - let taskPerformance = this.beginTaskPerformance(message) + let taskPerformance = this.beginTaskPerformance() fn(message.data) .then(res => { taskPerformance = this.endTaskPerformance(taskPerformance) @@ -297,13 +297,9 @@ export abstract class AbstractWorker< return fn } - private beginTaskPerformance (message: MessageValue): TaskPerformance { - const timestamp = performance.now() + private beginTaskPerformance (): TaskPerformance { return { - timestamp, - ...(this.statistics.waitTime && { - waitTime: timestamp - (message.timestamp ?? timestamp) - }), + timestamp: performance.now(), ...(this.statistics.elu && { elu: performance.eventLoopUtilization() }) } }