X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerAbstract.ts;h=c3e0ed88e9ae6fa4581b6e99b65bffa20931a546;hb=d2971a4b3d274f5b79df906a335c6c3b6725b025;hp=7c662d9dead4aa46e519b2519d1e560c774615b8;hpb=c3ee95af4edd541595e3873c8aa4c93d38e59474;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerAbstract.ts b/src/worker/WorkerAbstract.ts index 7c662d9d..c3e0ed88 100644 --- a/src/worker/WorkerAbstract.ts +++ b/src/worker/WorkerAbstract.ts @@ -1,9 +1,10 @@ +import { WorkerData, WorkerOptions } from '../types/Worker'; + import Constants from '../utils/Constants'; -import { WorkerData } from '../types/Worker'; export default abstract class WorkerAbstract { protected readonly workerScript: string; - protected readonly workerStartDelay: number; + protected readonly workerOptions: WorkerOptions; public abstract readonly size: number; public abstract readonly maxElementsPerWorker: number | null; @@ -11,11 +12,24 @@ export default abstract class WorkerAbstract { * `WorkerAbstract` constructor. * * @param workerScript - * @param workerStartDelay + * @param workerOptions */ - constructor(workerScript: string, workerStartDelay: number = Constants.WORKER_START_DELAY) { + constructor( + workerScript: string, + workerOptions: WorkerOptions = { + workerStartDelay: Constants.WORKER_START_DELAY, + elementStartDelay: Constants.ELEMENT_START_DELAY, + poolMinSize: Constants.DEFAULT_WORKER_POOL_MIN_SIZE, + poolMaxSize: Constants.DEFAULT_WORKER_POOL_MAX_SIZE, + elementsPerWorker: Constants.DEFAULT_CHARGING_STATIONS_PER_WORKER, + poolOptions: {}, + messageHandler: () => { + /* This is intentional */ + }, + } + ) { this.workerScript = workerScript; - this.workerStartDelay = workerStartDelay; + this.workerOptions = workerOptions; } public abstract start(): Promise;