wdev007
diff --git a/‎src/workers/fibonacciWorker.js‎
Lines changed: 23 additions & 0 deletions b/‎src/workers/fibonacciWorker.js‎
Lines changed: 23 additions & 0 deletions
diff --git a/‎src/workers/fibonacciWorker/index.js‎
Lines changed: 0 additions & 18 deletions b/‎src/workers/fibonacciWorker/index.js‎
Lines changed: 0 additions & 18 deletions
diff --git a/‎src/workers/fibonacciWorker/worker.js‎
Lines changed: 0 additions & 8 deletions b/‎src/workers/fibonacciWorker/worker.js‎
Lines changed: 0 additions & 8 deletions
@@ -0,0 +1,23 @@
+const fb = require('fibonacci');
+const { Worker, isMainThread, parentPort, workerData } = require('worker_threads');
+
+const runFibonacci = workerData => {
+  return new Promise((resolve, reject) => {
+    const worker = new Worker(__filename, { workerData });
+    worker.on('message', resolve);
+    worker.on('error', reject);
+    worker.on('exit', code => {
+      if (code !== 0) reject(new Error(`Worker stopped with exit code ${code}`));
+    });
+  });
+};
+
+/**
+ * If it's not the main thread it's one of the Worker threads
+ */
+if (!isMainThread) {
+  const result = fb.iterate(workerData.iterations);
+  parentPort.postMessage(result);
+}
+
+module.exports = runFibonacci;