X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerConstants.ts;h=ded5c89142f8e2aa9f485ed9df6ea476a7832100;hb=6e177b76d80dc30e471ec9f3500560285c48fc0f;hp=bbfcdac4b10a37b55adf26ee21d5385517b97ca9;hpb=769d3b106c5e4744487bc633da4e4ee93f8f1bf4;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerConstants.ts b/src/worker/WorkerConstants.ts index bbfcdac4..ded5c891 100644 --- a/src/worker/WorkerConstants.ts +++ b/src/worker/WorkerConstants.ts @@ -1,30 +1,31 @@ -import { type ThreadPoolOptions, availableParallelism } from 'poolifier'; +import { availableParallelism } from 'poolifier' -import type { WorkerOptions } from './WorkerTypes'; +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 POOL_MAX_INACTIVE_TIME = 60000; -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: {}, -}); - -export const DEFAULT_POOL_OPTIONS: ThreadPoolOptions = { - enableEvents: true, - restartWorkerOnError: true, -}; + poolOptions: { + startWorkers: false, + enableEvents: true, + restartWorkerOnError: true, + errorHandler: defaultErrorHandler, + exitHandler: defaultExitHandler + } +})