X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fthread%2Ffixed.ts;h=bc665bf1a5f13e6c136a7281b96ffc465e470c03;hb=243a550a93e278669fe5602aeba92dc8ba11260e;hp=2c4f66f0ff4d8be12d192f4028b1b1a17262bbc7;hpb=c2ade475e1b3b24aa2a1757b6d97a26063ec708c;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index 2c4f66f0..bc665bf1 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -45,12 +45,12 @@ export class FixedThreadPool< super(numberOfThreads, filePath, opts) } - /** {@inheritDoc} */ + /** @inheritDoc */ protected isMain (): boolean { return isMainThread } - /** {@inheritDoc} */ + /** @inheritDoc */ public async destroyWorker ( worker: ThreadWorkerWithMessageChannel ): Promise { @@ -58,7 +58,7 @@ export class FixedThreadPool< await worker.terminate() } - /** {@inheritDoc} */ + /** @inheritDoc */ protected sendToWorker ( worker: ThreadWorkerWithMessageChannel, message: MessageValue @@ -66,7 +66,7 @@ export class FixedThreadPool< worker.postMessage(message) } - /** {@inheritDoc} */ + /** @inheritDoc */ public registerWorkerMessageListener( messageChannel: ThreadWorkerWithMessageChannel, listener: (message: MessageValue) => void @@ -74,14 +74,14 @@ export class FixedThreadPool< messageChannel.port2?.on('message', listener) } - /** {@inheritDoc} */ + /** @inheritDoc */ protected createWorker (): ThreadWorkerWithMessageChannel { return new Worker(this.filePath, { env: SHARE_ENV }) } - /** {@inheritDoc} */ + /** @inheritDoc */ protected afterWorkerSetup (worker: ThreadWorkerWithMessageChannel): void { const { port1, port2 } = new MessageChannel() worker.postMessage({ parent: port1 }, [port1]) @@ -91,17 +91,17 @@ export class FixedThreadPool< this.registerWorkerMessageListener(worker, super.workerListener()) } - /** {@inheritDoc} */ + /** @inheritDoc */ public get type (): PoolType { return PoolType.FIXED } - /** {@inheritDoc} */ + /** @inheritDoc */ public get full (): boolean { - return this.workers.length === this.numberOfWorkers + return this.workerNodes.length === this.numberOfWorkers } - /** {@inheritDoc} */ + /** @inheritDoc */ public get busy (): boolean { return this.internalBusy() }