X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=a95a86034fcf13abc471862bbe9d51d8aa4604d1;hb=9eae7f2bf8939eaa61474e358835c1b2f13a754c;hp=2c4f66f0ff4d8be12d192f4028b1b1a17262bbc7;hpb=c2ade475e1b3b24aa2a1757b6d97a26063ec708c;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index 2c4f66f0..a95a8603 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 } - /** {@inheritDoc} */ + /** @inheritDoc */ public get busy (): boolean { return this.internalBusy() }