wip

Node/forkpi.js

@@ -6,12 +6,13 @@
 //
 const points = 1e8
 const { fork } = require('child_process')
-var processes = 1
+var processes = parseInt(process.argv[2])
 var pi = 0
 var results = 0
 var tstart = Date.now()/1000
-const forked = fork('child.js','1')
-forked.on('message',(result) => {
+for (let i = 0; i < processes; ++i) {
+   id = fork('forkspi.js',[i,points])
+   id.on('message',(result) => {
    pi += result
    results += 1
       if (results == processes) {
@@ -24,3 +25,4 @@ forked.on('message',(result) => {
          process.exit()
          }
       })
+   }

Node/forkspi.js

 //
-// clusterpi.js
+// forkspi.js
 // Neil Gershenfeld 11/23/18
 // pi calculation benchmark
 // pi = 3.14159265358979323846
 //
-
-
-const points = 1e8
-
-const { fork } = require('child_process');
-
-const forked = fork('child.js');
-
-forked.on('message', (msg) => {
-  console.log('Message from child', msg);
-});
-
-forked.send({ hello: 'world' });
-
-process.on('message', (msg) => {
-  console.log('Message from parent:', msg);
-});
-
-let counter = 0;
-
-setInterval(() => {
-  process.send({ counter: counter++ });
-}, 1000);
-
-function master() {
-   var processes = require('os').cpus().length
-   var tstart = Date.now()/1000
-   for (var i = 0; i < processes; i++)
-      cluster.fork()
-   var index = 0
-   var pi = 0
-   var results = 0
-   for (const id in cluster.workers) {
-      var worker = cluster.workers[id]
-      worker.on('message',(result) => {
-         pi += result
-         results += 1
-         if (results == processes) {
-            var tend = Date.now()/1000
-            var mflops = (processes*points)*5.0*1e-6/(tend-tstart)
-            console.log('pi: '+pi)
-            console.log('time: '+(tend-tstart).toFixed(1)+'s')
-            console.log('processes: '+processes)
-            console.log('estimated MFlops: '+mflops.toFixed(1))
-            process.exit()
-            }
-         })
-      function send(index) {
-         return function() {
-            worker.send(index)
-            }
-         }
-      worker.on('online',send(index))
-      index += 1
-      }
-   }
-function child() { 
-   process.on('message',(index) => {
+var index = parseInt(process.argv[2])
+var points = parseInt(process.argv[3])
 var a = 0.5
 var b = 0.75
 var c = 0.25
@@ -71,5 +15,3 @@ function child() {
 for (var i = start; i <= end; ++i)
    sum += a/((i-b)*(i-c))
 process.send(sum)
-      })
-   }