X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FWorker.ts;h=8a9e9f91198b1d70f3b9fd7246097bdd9678ca7a;hb=c96c65446db22c81ae48714691dbf974a8141b1d;hp=8bb9d1077b934f8d295eed40bdd108ad3cfedb4d;hpb=ff70d2ede1dd580df1be35ba4837c9a4f04314df;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/Worker.ts b/src/charging-station/Worker.ts index 8bb9d107..8a9e9f91 100644 --- a/src/charging-station/Worker.ts +++ b/src/charging-station/Worker.ts @@ -1,30 +1,31 @@ -import { Worker, WorkerOptions } from 'worker_threads'; - import Configuration from '../utils/Configuration'; import Constants from '../utils/Constants'; -import Pool from 'worker-threads-pool'; +import { Worker } from 'worker_threads'; import WorkerData from '../types/WorkerData'; +import WorkerPool from './WorkerPool'; export default class Wrk { - private _workerScript: string; - private _workerData: WorkerData; - private _worker: Worker; - private _maxWorkerElements: number; - private _numWorkerElements: number; + private workerScript: string; + private workerData: WorkerData; + private worker: Worker; + private maxWorkerElements: number; + private numWorkerElements: number; /** * Create a new `Wrk`. * * @param {string} workerScript * @param {WorkerData} workerData + * @param {number} maxWorkerElements */ constructor(workerScript: string, workerData: WorkerData, maxWorkerElements = 1) { - this._workerData = workerData; - this._workerScript = workerScript; - this._maxWorkerElements = maxWorkerElements; - this._numWorkerElements = 0; + this.workerData = workerData; + this.workerScript = workerScript; if (Configuration.useWorkerPool()) { WorkerPool.maxConcurrentWorkers = Configuration.getWorkerPoolMaxSize(); + } else { + this.maxWorkerElements = maxWorkerElements; + this.numWorkerElements = 0; } } @@ -35,11 +36,11 @@ export default class Wrk { */ async start(): Promise { if (Configuration.useWorkerPool()) { - await this._startWorkerWithPool(); + await this.startWorkerPool(); } else { - await this._startWorker(); + await this.startWorker(); } - return this._worker; + return this.worker; } /** @@ -51,12 +52,12 @@ export default class Wrk { if (Configuration.useWorkerPool()) { throw Error('Cannot add Wrk element if the worker pool is enabled'); } - if (this._numWorkerElements >= this._maxWorkerElements) { + if (this.numWorkerElements >= this.maxWorkerElements) { throw Error('Cannot add Wrk element: max number of elements per worker reached'); } - this._workerData = workerData; - this._worker.postMessage({ id: Constants.START_WORKER_ELEMENT, workerData: workerData }); - this._numWorkerElements++; + this.workerData = workerData; + this.worker.postMessage({ id: Constants.START_WORKER_ELEMENT, workerData: workerData }); + this.numWorkerElements++; } /** @@ -75,15 +76,15 @@ export default class Wrk { * @return {Promise} * @private */ - private async _startWorkerWithPool() { + private async startWorkerPool() { return new Promise((resolve, reject) => { - WorkerPool.acquire(this._workerScript, { workerData: this._workerData }, (err, worker) => { + WorkerPool.acquire(this.workerScript, { workerData: this.workerData }, (err, worker) => { if (err) { return reject(err); } worker.once('message', resolve); worker.once('error', reject); - this._worker = worker; + this.worker = worker; }); }); } @@ -93,9 +94,9 @@ export default class Wrk { * @return {Promise} * @private */ - private async _startWorker() { + private async startWorker() { return new Promise((resolve, reject) => { - const worker = new Worker(this._workerScript, { workerData: this._workerData }); + const worker = new Worker(this.workerScript, { workerData: this.workerData }); worker.on('message', resolve); worker.on('error', reject); worker.on('exit', (code) => { @@ -103,31 +104,8 @@ export default class Wrk { reject(new Error(`Worker stopped with exit code ${code}`)); } }); - this._numWorkerElements++; - this._worker = worker; + this.numWorkerElements++; + this.worker = worker; }); } } - - -class WorkerPool { - public static maxConcurrentWorkers: number; - private static _instance: Pool; - - private constructor() { } - - public static getInstance(): Pool { - if (!WorkerPool._instance) { - WorkerPool._instance = new Pool({ max: WorkerPool.maxConcurrentWorkers }); - } - return WorkerPool._instance; - } - - public static acquire(filename: string, options: WorkerOptions, callback: (error: Error | null, worker: Worker) => void): void { - WorkerPool.getInstance().acquire(filename, options, callback); - } - - public static getPoolSize(): number { - return WorkerPool.getInstance().size; - } -}