X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fcluster%2Ffixed.ts;h=09c5e369a5459d0858559a29eef8e9fc3a563c66;hb=refs%2Ftags%2Fv2.3.1;hp=9d162d8983a7bdce2a68b19e040392be40e83cd4;hpb=1d43bc4ccfb270c40e111aadb57c2a75fec828aa;p=poolifier.git diff --git a/src/pools/cluster/fixed.ts b/src/pools/cluster/fixed.ts index 9d162d89..09c5e369 100644 --- a/src/pools/cluster/fixed.ts +++ b/src/pools/cluster/fixed.ts @@ -1,8 +1,8 @@ import type { Worker } from 'cluster' import cluster from 'cluster' import type { MessageValue } from '../../utility-types' -import type { PoolOptions } from '../abstract-pool' import { AbstractPool } from '../abstract-pool' +import type { PoolOptions } from '../pool' import { PoolType } from '../pool-internal' /** @@ -49,30 +49,30 @@ export class FixedClusterPool< super(numberOfWorkers, filePath, opts) } - /** @inheritdoc */ + /** @inheritDoc */ protected setupHook (): void { cluster.setupPrimary({ exec: this.filePath }) } - /** @inheritdoc */ + /** @inheritDoc */ protected isMain (): boolean { return cluster.isPrimary } - /** @inheritdoc */ + /** @inheritDoc */ public destroyWorker (worker: Worker): void { this.sendToWorker(worker, { kill: 1 }) worker.kill() } - /** @inheritdoc */ + /** @inheritDoc */ protected sendToWorker (worker: Worker, message: MessageValue): void { worker.send(message) } - /** @inheritdoc */ + /** @inheritDoc */ public registerWorkerMessageListener ( worker: Worker, listener: (message: MessageValue) => void @@ -80,23 +80,23 @@ export class FixedClusterPool< worker.on('message', listener) } - /** @inheritdoc */ + /** @inheritDoc */ protected createWorker (): Worker { return cluster.fork(this.opts.env) } - /** @inheritdoc */ + /** @inheritDoc */ protected afterWorkerSetup (worker: Worker): void { // Listen worker messages. this.registerWorkerMessageListener(worker, super.workerListener()) } - /** @inheritdoc */ + /** @inheritDoc */ public get type (): PoolType { return PoolType.FIXED } - /** @inheritdoc */ + /** @inheritDoc */ public get busy (): boolean { return this.internalGetBusyStatus() }