import { parentPort, workerData } from 'worker_threads';
import ChargingStation from './ChargingStation';
-import Constants from '../utils/Constants';
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()) {
threadWorker = new ThreadWorker<ChargingStationWorkerData>(startChargingStation, {
- maxInactiveTime: Constants.WORKER_POOL_MAX_INACTIVE_TIME,
+ maxInactiveTime: WorkerConstants.POOL_MAX_INACTIVE_TIME,
async: false,
});
} else {
addMessageListener();
if (!Utils.isUndefined(workerData)) {
startChargingStation({
- index: workerData.index as number,
- templateFile: workerData.templateFile as string,
+ index: (workerData as ChargingStationWorkerData).index,
+ templateFile: (workerData as ChargingStationWorkerData).templateFile,
});
}
}