X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FChargingStationWorker.ts;h=60d065642c7ef94585aa6902bf839354339dc6aa;hb=e64c6fa982ba3270bb015deea30eece32b4661de;hp=4361ab9badd0a6f0e6d80b82f16e62a8fed0a804;hpb=e8a92d57004dcddba34fa4a510226b56e11a8cdb;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ChargingStationWorker.ts b/src/charging-station/ChargingStationWorker.ts index 4361ab9b..60d06564 100644 --- a/src/charging-station/ChargingStationWorker.ts +++ b/src/charging-station/ChargingStationWorker.ts @@ -4,9 +4,9 @@ import { parentPort, workerData } from 'node:worker_threads'; import { ThreadWorker } from 'poolifier'; -import { ChargingStation, ChargingStationUtils } from './internal'; +import { ChargingStation } from './ChargingStation'; import type { ChargingStationWorkerData } from '../types'; -import { Utils } from '../utils'; +import { Configuration } from '../utils'; import { WorkerConstants, type WorkerMessage, WorkerMessageEvents } from '../worker'; /** @@ -32,15 +32,14 @@ const addMessageListener = (): void => { // Conditionally export ThreadWorker instance for pool usage export let threadWorker: ThreadWorker; -if (ChargingStationUtils.workerPoolInUse()) { +if (Configuration.workerPoolInUse()) { threadWorker = new ThreadWorker(startChargingStation, { maxInactiveTime: WorkerConstants.POOL_MAX_INACTIVE_TIME, - async: false, }); } else { // Add message listener to start charging station from main thread addMessageListener(); - if (Utils.isUndefined(workerData) === false) { + if (workerData !== undefined) { startChargingStation(workerData as ChargingStationWorkerData); } }