X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fcluster%2Ffixed.ts;h=09c5e369a5459d0858559a29eef8e9fc3a563c66;hb=d8a610ca5afeb75608704cddf0093f024134239c;hp=9844c4a8a912570c10043e4980b8bb3113aab6f1;hpb=7e0d447f83e76296d95fc71dcdcfbe6fa2fe1f26;p=poolifier.git diff --git a/src/pools/cluster/fixed.ts b/src/pools/cluster/fixed.ts index 9844c4a8..09c5e369 100644 --- a/src/pools/cluster/fixed.ts +++ b/src/pools/cluster/fixed.ts @@ -1,7 +1,8 @@ -import cluster, { Worker } from 'cluster' +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' /** @@ -48,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 @@ -79,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() }