X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerFactory.ts;h=34369e186b06c03c683b4a0ece10c7e898e864b2;hb=aa8cbc5c65e51e1d7c955186847b7105a292d42f;hp=41fa1d89715444ca5cd69b07f6684789f63b2ecc;hpb=95250e1b3f40c916420bb693502fda4b0e49ac33;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerFactory.ts b/src/worker/WorkerFactory.ts index 41fa1d89..34369e18 100644 --- a/src/worker/WorkerFactory.ts +++ b/src/worker/WorkerFactory.ts @@ -1,6 +1,6 @@ import { WorkerOptions, WorkerProcessType } from '../types/Worker'; -import Utils from '../utils/Utils'; +import Constants from '../utils/Constants'; import WorkerAbstract from './WorkerAbstract'; import WorkerDynamicPool from './WorkerDynamicPool'; import WorkerSet from './WorkerSet'; @@ -12,28 +12,19 @@ export default class WorkerFactory { if (!isMainThread) { throw new Error('Trying to get a worker implementation outside the main thread'); } - if (Utils.isUndefined(options)) { - options = {} as WorkerOptions; - } + options = options ?? {} as WorkerOptions; + options.startDelay = options.startDelay ?? Constants.WORKER_START_DELAY; switch (workerProcessType) { case WorkerProcessType.WORKER_SET: - if (Utils.isUndefined(options.elementsPerWorker)) { - options.elementsPerWorker = 1; - } - return new WorkerSet(workerScript, options.elementsPerWorker); + options.elementsPerWorker = options.elementsPerWorker ?? 1; + return new WorkerSet(workerScript, options.elementsPerWorker, options.startDelay); case WorkerProcessType.STATIC_POOL: - if (Utils.isUndefined(options.poolMaxSize)) { - options.poolMaxSize = 16; - } - return new WorkerStaticPool(workerScript, options.poolMaxSize); + options.poolMaxSize = options.poolMaxSize ?? 16; + return new WorkerStaticPool(workerScript, options.poolMaxSize, options.startDelay); case WorkerProcessType.DYNAMIC_POOL: - if (Utils.isUndefined(options.poolMinSize)) { - options.poolMinSize = 4; - } - if (Utils.isUndefined(options.poolMaxSize)) { - options.poolMaxSize = 16; - } - return new WorkerDynamicPool(workerScript, options.poolMinSize, options.poolMaxSize); + options.poolMinSize = options.poolMinSize ?? 4; + options.poolMaxSize = options.poolMaxSize ?? 16; + return new WorkerDynamicPool(workerScript, options.poolMinSize, options.poolMaxSize, options.startDelay); default: return null; }