X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Fdynamic.ts;h=90889c9b2572728ba7145da8e3a5c04bfa3c3378;hb=afa30fd0dd5bbc5d305cc30be663966a449efc08;hp=bb177f876c79893b582989d67067b4ec448b2549;hpb=027063571693f211b35c8851566a063201adb9af;p=poolifier.git diff --git a/src/pools/thread/dynamic.ts b/src/pools/thread/dynamic.ts index bb177f87..90889c9b 100644 --- a/src/pools/thread/dynamic.ts +++ b/src/pools/thread/dynamic.ts @@ -1,7 +1,5 @@ -import type { PoolOptions } from '../pool' -import { PoolType } from '../pool' -import type { ThreadWorkerWithMessageChannel } from './fixed' -import { FixedThreadPool } from './fixed' +import { type PoolOptions, type PoolType, PoolTypes } from '../pool' +import { FixedThreadPool, type ThreadWorkerWithMessageChannel } from './fixed' /** * A thread pool with a dynamic number of threads, but a guaranteed minimum number of threads. @@ -28,7 +26,7 @@ export class DynamicThreadPool< */ public constructor ( min: number, - public readonly max: number, + protected readonly max: number, filePath: string, opts: PoolOptions = {} ) { @@ -36,13 +34,13 @@ export class DynamicThreadPool< } /** @inheritDoc */ - public get type (): PoolType { - return PoolType.DYNAMIC + protected get type (): PoolType { + return PoolTypes.dynamic } /** @inheritDoc */ - protected get full (): boolean { - return this.workerNodes.length === this.max + protected get maxSize (): number { + return this.max } /** @inheritDoc */