WorkerFactory.ts: Use nullish coalescing operator
[e-mobility-charging-stations-simulator.git] / src / worker / WorkerFactory.ts
CommitLineData
b8da29bc
JB
1import { WorkerOptions, WorkerProcessType } from '../types/Worker';
2
3import Utils from '../utils/Utils';
fd1fdf1b 4import WorkerAbstract from './WorkerAbstract';
a4624c96 5import WorkerDynamicPool from './WorkerDynamicPool';
6013bc53 6import WorkerSet from './WorkerSet';
a4624c96 7import WorkerStaticPool from './WorkerStaticPool';
ded13d97 8import { isMainThread } from 'worker_threads';
6013bc53
JB
9
10export default class WorkerFactory {
fd1fdf1b 11 public static getWorkerImplementation<T>(workerScript: string, workerProcessType: WorkerProcessType, options?: WorkerOptions): WorkerAbstract {
ded13d97
JB
12 if (!isMainThread) {
13 throw new Error('Trying to get a worker implementation outside the main thread');
14 }
b8da29bc
JB
15 if (Utils.isUndefined(options)) {
16 options = {} as WorkerOptions;
17 }
18 switch (workerProcessType) {
a4624c96 19 case WorkerProcessType.WORKER_SET:
863cef22 20 options.elementsPerWorker = options.elementsPerWorker ?? 1;
8434025b 21 return new WorkerSet<T>(workerScript, options.elementsPerWorker);
a4624c96 22 case WorkerProcessType.STATIC_POOL:
863cef22 23 options.poolMaxSize = options.poolMaxSize ?? 16;
8434025b 24 return new WorkerStaticPool<T>(workerScript, options.poolMaxSize);
a4624c96 25 case WorkerProcessType.DYNAMIC_POOL:
863cef22
JB
26 options.poolMinSize = options.poolMinSize ?? 4;
27 options.poolMaxSize = options.poolMaxSize ?? 16;
8434025b 28 return new WorkerDynamicPool<T>(workerScript, options.poolMinSize, options.poolMaxSize);
a4624c96
JB
29 default:
30 return null;
6013bc53 31 }
6013bc53
JB
32 }
33}