X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fpool-internal.ts;h=b245e360df704ee1e7fde5ce4e114da060cc70fd;hb=243a550a93e278669fe5602aeba92dc8ba11260e;hp=c3ec39bea578d3de3c0423f2ef789e0cd6c6f9df;hpb=dba3384e0e6bc4049cb114d32e053cc4f2abe010;p=poolifier.git diff --git a/src/pools/pool-internal.ts b/src/pools/pool-internal.ts index c3ec39be..b245e360 100644 --- a/src/pools/pool-internal.ts +++ b/src/pools/pool-internal.ts @@ -1,5 +1,5 @@ import type { IPool } from './pool' -import type { IPoolWorker } from './pool-worker' +import type { IWorker, WorkerNode } from './worker' /** * Internal pool types. @@ -7,31 +7,16 @@ import type { IPoolWorker } from './pool-worker' * @enum */ export enum PoolType { + /** + * Fixed pool type. + */ FIXED = 'fixed', + /** + * Dynamic pool type. + */ DYNAMIC = 'dynamic' } -/** - * Internal tasks usage statistics. - */ -export interface TasksUsage { - run: number - running: number - runTime: number - avgRunTime: number - error: number -} - -/** - * Internal worker type. - * - * @typeParam Worker - Type of worker type items which manages this pool. - */ -export interface WorkerType { - worker: Worker - tasksUsage: TasksUsage -} - /** * Internal contract definition for a poolifier pool. * @@ -40,14 +25,14 @@ export interface WorkerType { * @typeParam Response - Type of response of execution. This can only be serializable data. */ export interface IPoolInternal< - Worker extends IPoolWorker, + Worker extends IWorker, Data = unknown, Response = unknown > extends IPool { /** - * Pool worker type items array. + * Pool worker nodes. */ - readonly workers: Array> + readonly workerNodes: Array> /** * Pool type. @@ -71,13 +56,13 @@ export interface IPoolInternal< readonly busy: boolean /** - * Finds a free worker key based on the number of tasks the worker has applied. + * Finds a free worker node key based on the number of tasks the worker has applied. * - * If a worker is found with `0` running tasks, it is detected as free and its key is returned. + * If a worker is found with `0` running tasks, it is detected as free and its worker node key is returned. * * If no free worker is found, `-1` is returned. * - * @returns A worker key if there is one, `-1` otherwise. + * @returns A worker node key if there is one, `-1` otherwise. */ - findFreeWorkerKey: () => number + findFreeWorkerNodeKey: () => number }