X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=bfd6f016d0d4f08525d1c19435d4a138e2a404a0;hb=838898f1dfd2d2456d3e9a832d24a7ef6f53be70;hp=ee3d63c12c7abe8c1583a56baa169d3a83afcbca;hpb=5c5a1fb79906f18560012263239e7bd611ee8d2b;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index ee3d63c1..bfd6f016 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -48,7 +48,6 @@ export class FixedThreadPool< worker: ThreadWorkerWithMessageChannel ): Promise { await worker.terminate() - // FIXME: The tests are currently failing, so these must be changed first } protected sendToWorker ( @@ -72,15 +71,13 @@ export class FixedThreadPool< port.port2?.removeListener('message', listener) } - protected newWorker (): ThreadWorkerWithMessageChannel { + protected createWorker (): ThreadWorkerWithMessageChannel { return new Worker(this.filePath, { env: SHARE_ENV }) } - protected afterNewWorkerPushed ( - worker: ThreadWorkerWithMessageChannel - ): void { + protected afterWorkerSetup (worker: ThreadWorkerWithMessageChannel): void { const { port1, port2 } = new MessageChannel() worker.postMessage({ parent: port1 }, [port1]) worker.port1 = port1