import { parentPort, workerData } from 'worker_threads';
import ChargingStation from './ChargingStation';
+import { ChargingStationUtils } from './ChargingStationUtils';
import { ThreadWorker } from 'poolifier';
import Utils from '../utils/Utils';
import WorkerConstants from '../worker/WorkerConstants';
// Conditionally export ThreadWorker instance for pool usage
export let threadWorker: ThreadWorker;
-if (Utils.workerPoolInUse()) {
+if (ChargingStationUtils.workerPoolInUse()) {
threadWorker = new ThreadWorker<ChargingStationWorkerData>(startChargingStation, {
maxInactiveTime: WorkerConstants.POOL_MAX_INACTIVE_TIME,
async: false,
// Add message listener to start charging station from main thread
addMessageListener();
if (!Utils.isUndefined(workerData)) {
- startChargingStation({
- index: (workerData as Record<string, unknown>).index as number,
- templateFile: (workerData as Record<string, unknown>).templateFile as string,
- });
+ startChargingStation(workerData as ChargingStationWorkerData);
}
}