X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerConstants.ts;h=ded5c89142f8e2aa9f485ed9df6ea476a7832100;hb=8fb8f42ace8b9295865adebaeb7845e064c05e71;hp=654e6f5e2e51782ea2168d3ccb94cdff2dd66fca;hpb=a6ef1ece74c0d08e86a905571f4f6045c28131cb;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerConstants.ts b/src/worker/WorkerConstants.ts index 654e6f5e..ded5c891 100644 --- a/src/worker/WorkerConstants.ts +++ b/src/worker/WorkerConstants.ts @@ -1,27 +1,31 @@ -import { availableParallelism } from 'poolifier'; +import { availableParallelism } from 'poolifier' -import type { WorkerOptions } from './WorkerTypes.js'; +import type { WorkerOptions } from './WorkerTypes.js' +import { defaultErrorHandler, defaultExitHandler } from './WorkerUtils.js' export const EMPTY_FUNCTION = Object.freeze(() => { /* This is intentional */ -}); +}) -export const workerSetVersion = '1.0.1'; +export const workerSetVersion = '1.0.1' -export const DEFAULT_ELEMENT_START_DELAY = 0; -export const DEFAULT_WORKER_START_DELAY = 500; -export const DEFAULT_POOL_MIN_SIZE = Math.floor(availableParallelism() / 2); -export const DEFAULT_POOL_MAX_SIZE = Math.round(availableParallelism() * 1.5); -export const DEFAULT_ELEMENTS_PER_WORKER = 1; +export const DEFAULT_ELEMENT_ADD_DELAY = 0 +export const DEFAULT_WORKER_START_DELAY = 500 +export const DEFAULT_POOL_MIN_SIZE = Math.floor(availableParallelism() / 2) +export const DEFAULT_POOL_MAX_SIZE = Math.round(availableParallelism() * 1.5) +export const DEFAULT_ELEMENTS_PER_WORKER = 1 export const DEFAULT_WORKER_OPTIONS: WorkerOptions = Object.freeze({ workerStartDelay: DEFAULT_WORKER_START_DELAY, - elementStartDelay: DEFAULT_ELEMENT_START_DELAY, + elementAddDelay: DEFAULT_ELEMENT_ADD_DELAY, poolMinSize: DEFAULT_POOL_MIN_SIZE, poolMaxSize: DEFAULT_POOL_MAX_SIZE, elementsPerWorker: DEFAULT_ELEMENTS_PER_WORKER, poolOptions: { + startWorkers: false, enableEvents: true, restartWorkerOnError: true, - }, -}); + errorHandler: defaultErrorHandler, + exitHandler: defaultExitHandler + } +})