Change cluster example and rename

Author: tshemsedinov

cluster/master.js

@@ -0,0 +1,42 @@
+'use strict';
+
+const os = require('os');
+const cluster = require('cluster');
+
+console.log('Started master:', process.pid);
+
+const cpuCount = os.cpus().length;
+const workers = [];
+for (let i = 0; i < cpuCount; i++) {
+  const worker = cluster.fork();
+  console.log('Started worker:', worker.process.pid);
+  workers.push(worker);
+}
+
+const task = [2, 17, 3, 2, 5, 7, 15, 22, 1, 14, 15, 9, 0, 11];
+const results = [];
+
+workers.forEach((worker) => {
+
+  worker.send({ task });
+
+  worker.on('exit', (code) => {
+    console.log('Worker exited:', worker.process.pid, code);
+  });
+
+  worker.on('message', (message) => {
+
+    console.log('Message from worker', worker.process.pid);
+    console.log(JSON.stringify(message));
+
+    results.push(message.result);
+
+    if (results.length === cpuCount) {
+      process.exit(0);
+    }
+
+  });
+
+  setTimeout(() => process.exit(1), 5000);
+
+});

workers/multicore.js cluster/multicore.jsworkers/multicore.js renamed to cluster/multicore.js

@@ -3,7 +3,7 @@
 const cluster = require('cluster');
 
 if (cluster.isMaster) {
-  require('./master.js')();
+  require('./master.js');
 } else {
-  require('./worker.js')();
+  require('./worker.js');
 }

cluster/worker.js

@@ -0,0 +1,17 @@
+'use strict';
+
+const cluster = require('cluster');
+
+console.log('Hello from worker', process.pid, cluster.worker.id);
+
+const caltulations = x => x * 2;
+
+process.on('message', (message) => {
+
+  console.log('Message to worker ', process.pid)
+  console.log(JSON.stringify(message));
+
+  const result = message.task.map(caltulations);
+  process.send({ result });
+
+});