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({
- // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
- index: workerData.index as number,
- // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
- templateFile: workerData.templateFile as string,
- });
+ startChargingStation(workerData as ChargingStationWorkerData);
}
}