X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=f0a49056bd3ef9c937abc10e7fc1dadc1bc3f50f;hb=a3ae469eebfcc990a251133beb01378599313233;hp=816fa61a432db55b0980092bb3bf7f45818c1364;hpb=1f68cedebde2cf95b6345300ac52cf7ca3ecbdff;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index 816fa61a..f0a49056 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -6,8 +6,13 @@ import { } from 'node:worker_threads' import type { Draft, MessageValue } from '../../utility-types' import { AbstractPool } from '../abstract-pool' -import type { PoolOptions } from '../pool' -import { PoolType } 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. @@ -92,18 +97,23 @@ export class FixedThreadPool< } /** @inheritDoc */ - public get type (): PoolType { - return PoolType.FIXED + protected get type (): PoolType { + return PoolTypes.fixed } /** @inheritDoc */ - public get size (): number { + protected get worker (): WorkerType { + return WorkerTypes.thread + } + + /** @inheritDoc */ + 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 */