src/pools/selection-strategies/abstract-worker-choice-strategy.ts

   1 import type { IPoolInternal } from '../pool-internal'
   2 import { PoolType } from '../pool-internal'
   3 import type { IPoolWorker } from '../pool-worker'
   4 import type {
   5   IWorkerChoiceStrategy,
   6   RequiredStatistics
   7 } from './selection-strategies-types'
   8
   9 /**
  10  * Abstract worker choice strategy class.
  11  *
  12  * @typeParam Worker - Type of worker which manages the strategy.
  13  * @typeParam Data - Type of data sent to the worker. This can only be serializable data.
  14  * @typeParam Response - Type of response of execution. This can only be serializable data.
  15  */
  16 export abstract class AbstractWorkerChoiceStrategy<
  17   Worker extends IPoolWorker,
  18   Data,
  19   Response
  20 > implements IWorkerChoiceStrategy<Worker> {
  21   /** {@inheritDoc} */
  22   public readonly isDynamicPool: boolean = this.pool.type === PoolType.DYNAMIC
  23   /** {@inheritDoc} */
  24   public requiredStatistics: RequiredStatistics = {
  25     runTime: false
  26   }
  27
  28   /**
  29    * Constructs a worker choice strategy attached to the pool.
  30    *
  31    * @param pool - The pool instance.
  32    */
  33   public constructor (
  34     protected readonly pool: IPoolInternal<Worker, Data, Response>
  35   ) {}
  36
  37   /** {@inheritDoc} */
  38   public abstract reset (): boolean
  39
  40   /** {@inheritDoc} */
  41   public abstract choose (): Worker
  42 }