benchmark: port cluster/echo to worker

 $ ./node benchmark/cluster/echo.js cluster/echo.js n=100000 sendsPerBroadcast=1 payload="string" workers=1: 33,647.30473442063 cluster/echo.js n=100000 sendsPerBroadcast=10 payload="string" workers=1: 12,927.907405288383 cluster/echo.js n=100000 sendsPerBroadcast=1 payload="object" workers=1: 28,496.37373941151 cluster/echo.js n=100000 sendsPerBroadcast=10 payload="object" workers=1: 8,975.53747186485 $ ./node --experimental-worker benchmark/worker/echo.js worker/echo.js n=100000 sendsPerBroadcast=1 payload="string" workers=1: 88,044.32902365089 worker/echo.js n=100000 sendsPerBroadcast=10 payload="string" workers=1: 39,873.33697018837 worker/echo.js n=100000 sendsPerBroadcast=1 payload="object" workers=1: 64,451.29132425621 worker/echo.js n=100000 sendsPerBroadcast=10 payload="object" workers=1: 22,325.635443739284 Refs: ayojs/ayo#115 Reviewed-By: Anna Henningsen <[email protected]> PR-URL: #20876 Reviewed-By: Gireesh Punathil <[email protected]> Reviewed-By: Benjamin Gruenbaum <[email protected]> Reviewed-By: Shingo Inoue <[email protected]> Reviewed-By: Matteo Collina <[email protected]> Reviewed-By: Tiancheng "Timothy" Gu <[email protected]> Reviewed-By: John-David Dalton <[email protected]> Reviewed-By: Gus Caplan <[email protected]>

Author: TimothyGu

benchmark/fixtures/echo.worker.js

@@ -0,0 +1,7 @@
+'use strict';
+
+const{ parentPort }=require('worker');
+
+parentPort.on('message',(msg)=>{
+parentPort.postMessage(msg);
+});

benchmark/worker/echo.js

@@ -0,0 +1,73 @@
+'use strict';
+
+constcommon=require('../common.js');
+constpath=require('path');
+constbench=common.createBenchmark(main,{
+workers: [1],
+payload: ['string','object'],
+sendsPerBroadcast: [1,10],
+n: [1e5]
+},{flags: ['--experimental-worker']});
+
+constworkerPath=path.resolve(__dirname,'..','fixtures','echo.worker.js');
+
+functionmain(conf){
+const{ Worker }=require('worker');
+
+constn=+conf.n;
+constworkers=+conf.workers;
+constsends=+conf.sendsPerBroadcast;
+constexpectedPerBroadcast=sends*workers;
+varpayload;
+varreadies=0;
+varbroadcasts=0;
+varmsgCount=0;
+
+switch(conf.payload){
+case'string':
+payload='hello world!';
+break;
+case'object':
+payload={action: 'pewpewpew',powerLevel: 9001};
+break;
+default:
+thrownewError('Unsupported payload type');
+}
+
+constworkerObjs=[];
+
+for(vari=0;i<workers;++i){
+constworker=newWorker(workerPath);
+workerObjs.push(worker);
+worker.on('online',onOnline);
+worker.on('message',onMessage);
+}
+
+functiononOnline(){
+if(++readies===workers){
+bench.start();
+broadcast();
+}
+}
+
+functionbroadcast(){
+if(broadcasts++===n){
+bench.end(n);
+for(constworkerofworkerObjs){
+worker.unref();
+}
+return;
+}
+for(constworkerofworkerObjs){
+for(vari=0;i<sends;++i)
+worker.postMessage(payload);
+}
+}
+
+functiononMessage(){
+if(++msgCount===expectedPerBroadcast){
+msgCount=0;
+broadcast();
+}
+}
+}