Add shared thread example

waldemarnt · waldemarnt · commit 293a22c5013b · 2019-07-28T16:08:53.000+10:00
diff --git a/src/workers/fibonacciWorker.js b/src/workers/fibonacciWorker.js
@@ -13,8 +13,8 @@ const runFibonacci = workerData => {
 };
 
 if (!isMainThread) {
-  const number = fb.iterate(workerData.iterations);
-  parentPort.postMessage({ number });
+  const result = fb.iterate(workerData.iterations);
+  parentPort.postMessage(result);
 }
 
 module.exports = runFibonacci;
diff --git a/src/workers/fibonacciWorkerPool.js b/src/workers/fibonacciWorkerPool.js
@@ -19,8 +19,8 @@ const runFibonacci = workerData => {
 };
 
 if (!isMainThread) {
-  const number = fb.iterate(workerData.iterations);
-  parentPort.postMessage({ number });
+  const result = fb.iterate(workerData.iterations);
+  parentPort.postMessage(result);
 }
 
 module.exports = runFibonacci;
diff --git a/src/workers/fibonacciWorkerShared.js b/src/workers/fibonacciWorkerShared.js
@@ -0,0 +1,25 @@
+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 (!isMainThread) {
+  const sharedArray = workerData.arr;
+  const result = fb.iterate(workerData.iterations);
+  /**
+   * Adds items to the shared array in a safe way
+   */
+  Atomics.add(sharedArray, workerData.position, result.ms);
+  parentPort.postMessage(sharedArray);
+}
+
+module.exports = runFibonacci;

Original file line number	Diff line number	Diff line change
`@@ -13,8 +13,8 @@ const runFibonacci = workerData => {`
`13`	`13`	`};`
`14`	`14`
`15`	`15`	`if (!isMainThread) {`
`16`		`- const number = fb.iterate(workerData.iterations);`
`17`		`- parentPort.postMessage({ number });`
	`16`	`+ const result = fb.iterate(workerData.iterations);`
	`17`	`+ parentPort.postMessage(result);`
`18`	`18`	`}`
`19`	`19`
`20`	`20`	`module.exports = runFibonacci;`
Original file line number	Diff line number	Diff line change
`@@ -19,8 +19,8 @@ const runFibonacci = workerData => {`
`19`	`19`	`};`
`20`	`20`
`21`	`21`	`if (!isMainThread) {`
`22`		`- const number = fb.iterate(workerData.iterations);`
`23`		`- parentPort.postMessage({ number });`
	`22`	`+ const result = fb.iterate(workerData.iterations);`
	`23`	`+ parentPort.postMessage(result);`
`24`	`24`	`}`
`25`	`25`
`26`	`26`	`module.exports = runFibonacci;`