X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=f0a49056bd3ef9c937abc10e7fc1dadc1bc3f50f;hb=a3ae469eebfcc990a251133beb01378599313233;hp=9939a04b9e497f5e78a84396493db7819f837508;hpb=f8350486e75b15ed17249cda3d0a55ee807a6a9f;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index 9939a04b..f0a49056 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -6,7 +6,13 @@ import { } from 'node:worker_threads' import type { Draft, MessageValue } from '../../utility-types' import { AbstractPool } from '../abstract-pool' -import { type PoolOptions, type PoolType, PoolTypes } from '../pool' +import { + type PoolOptions, + type PoolType, + PoolTypes, + type WorkerType, + WorkerTypes +} from '../pool' /** * A thread worker with message channels for communication between main thread and thread worker. @@ -91,23 +97,23 @@ export class FixedThreadPool< } /** @inheritDoc */ - public get type (): PoolType { + protected get type (): PoolType { return PoolTypes.fixed } /** @inheritDoc */ - protected get minSize (): number { - return this.numberOfWorkers + protected get worker (): WorkerType { + return WorkerTypes.thread } /** @inheritDoc */ - protected get maxSize (): number { + protected get minSize (): number { return this.numberOfWorkers } /** @inheritDoc */ - protected get full (): boolean { - return this.workerNodes.length >= this.numberOfWorkers + protected get maxSize (): number { + return this.numberOfWorkers } /** @inheritDoc */