Add files via upload

jaydattpatel · web-flow · commit 0b2699a3a4ec · 2024-07-14T19:51:41.000+05:30
diff --git a/CoWorker-Thread/Co-WorkerThreads.mp4 b/CoWorker-Thread/Co-WorkerThreads.mp4
diff --git a/CoWorker-Thread/Main.js b/CoWorker-Thread/Main.js
@@ -0,0 +1,31 @@
+import { Worker, isMainThread, parentPort } from "node:worker_threads";
+
+if (isMainThread) {
+  const CPU_core = 10;
+  for (let i = 0; i < CPU_core; i++) {
+    // Create a new worker thread
+    const worker = new Worker("./worker.js");
+    // pass value to the worker thread
+    worker.postMessage([
+      `Thread-${i + 1}`,
+      Math.ceil(Math.random() * 10) * 1000000000,
+    ]);
+    // Listen for messages from the worker thread
+    worker.on("message", (result) => {
+      console.log(`${result} is done.`);
+      worker.terminate(); // Terminate the worker thread
+    });
+    // Handle errors in the worker thread
+    worker.on("error", (err) => {
+      console.error(`Worker error: ${err}`);
+    });
+  }
+  console.log("waiting to complete....");
+} else {
+  // This code is executed in the as worker thread mode
+  parentPort.on("message", (message) => {
+    console.log(`Received message from Other thread: ${message}`);
+    // Perform some task (in this case, just echoing the message)
+    parentPort.postMessage(`Hello from worker! Received: ${message}`);
+  });
+}
diff --git a/CoWorker-Thread/package.json b/CoWorker-Thread/package.json
@@ -0,0 +1,12 @@
+{
+  "name": "coworker-thread",
+  "version": "1.0.0",
+  "main": "Main.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "type": "module",
+  "author": "jaydatt",
+  "license": "ISC",
+  "description": ""
+}
diff --git a/CoWorker-Thread/worker.js b/CoWorker-Thread/worker.js
@@ -0,0 +1,20 @@
+import { parentPort } from "worker_threads";
+
+function performTask(n) {
+  let result = 0;
+  for (let i = 0; i <= n; i++) {
+    result += i;
+    // console.log(i);
+  }
+}
+
+// Listen for messages from the parent thread
+parentPort.on("message", (arr) => {
+  console.log(`Received from parent thread: ${arr}`);
+
+  // Perform the task
+  performTask(arr[1]);
+
+  // Send the result back to the parent thread
+  parentPort.postMessage(arr[0]);
+});
