1 import type { AbstractPoolWorker
} from
'../abstract-pool-worker'
2 import { AbstractWorkerChoiceStrategy
} from
'./abstract-worker-choice-strategy'
5 * Selects the less recently used worker.
7 * @template Worker Type of worker which manages the strategy.
8 * @template Data Type of data sent to the worker. This can only be serializable data.
9 * @template Response Type of response of execution. This can only be serializable data.
11 export class LessRecentlyUsedWorkerChoiceStrategy
<
12 Worker
extends AbstractPoolWorker
,
15 > extends AbstractWorkerChoiceStrategy
<Worker
, Data
, Response
> {
17 public choose (): Worker
{
18 let minNumberOfRunningTasks
= Infinity
19 // A worker is always found because it picks the one with fewer tasks
20 let lessRecentlyUsedWorker
!: Worker
21 for (const worker
of this.pool
.workers
) {
22 const workerRunningTasks
= this.pool
.getWorkerRunningTasks(
25 if (this.isDynamicPool
=== false && workerRunningTasks
=== 0) {
27 } else if (workerRunningTasks
< minNumberOfRunningTasks
) {
28 lessRecentlyUsedWorker
= worker
29 minNumberOfRunningTasks
= workerRunningTasks
32 return lessRecentlyUsedWorker