X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=7199baf8fdf5ad52bc43bcfdfe107de84719589a;hb=c2301b8e5ab9a84e16dd037c6f7e3e85030bb266;hp=a575d0972ff6611fadcbb662e195f31bf118a6d7;hpb=daf86646c7cdb484ec05165a49c12224da11a4c7;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index a575d097..7199baf8 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -61,7 +61,7 @@ export class FixedThreadPool< // FIXME: wait for tasks to be finished const workerNode = this.workerNodes[workerNodeKey] const worker = workerNode.worker - const workerExitPromise = new Promise(resolve => { + const waitWorkerExit = new Promise(resolve => { worker.on('exit', () => { resolve() }) @@ -69,7 +69,7 @@ export class FixedThreadPool< this.sendToWorker(workerNodeKey, { kill: true, workerId: worker.threadId }) workerNode.closeChannel() await worker.terminate() - await workerExitPromise + await waitWorkerExit } /** @inheritDoc */