X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=13e4a11a50028364c055b6b60aca5cb03b87fcfd;hb=1e3214b63e262557aadebf3c57e8388de6a4bbe4;hp=a193091f9fc7e1c4ac16c92a359eac470c0f6e78;hpb=07588f306649b9df235aaf65de4842e99532ed6a;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index a193091f..13e4a11a 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -67,7 +67,7 @@ export class FixedThreadPool< resolve() }) }) - this.sendToWorker(workerNodeKey, { kill: true, workerId: worker.threadId }) + await this.sendKillMessageToWorker(workerNodeKey, worker.threadId) workerNode.closeChannel() await worker.terminate() await waitWorkerExit