Add WorkerPool file

Signed-off-by: Jérôme Benoit <jerome.benoit@sap.com>

diff --git a/src/charging-station/WorkerPool.ts b/src/charging-station/WorkerPool.ts
new file mode 100644 (file)
index 0000000..40c284e
--- /dev/null
+++ b/src/charging-station/WorkerPool.ts
@@ -0,0 +1,25 @@
+import { Worker, WorkerOptions } from 'worker_threads';
+
+import Pool from 'worker-threads-pool';
+
+export default 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;
+  }
+}