From c7c22e3db1c826bcfb2bc66651ec480aae0d4ae0 Mon Sep 17 00:00:00 2001 From: yo mama Date: Sat, 4 Apr 2015 01:00:59 -0700 Subject: first --- .../test/test15_emit_ping_pong.js | 31 ++++++++++++++++++++++ 1 file changed, 31 insertions(+) create mode 100644 node_modules/webworker-threads/test/test15_emit_ping_pong.js (limited to 'node_modules/webworker-threads/test/test15_emit_ping_pong.js') diff --git a/node_modules/webworker-threads/test/test15_emit_ping_pong.js b/node_modules/webworker-threads/test/test15_emit_ping_pong.js new file mode 100644 index 0000000..98946a6 --- /dev/null +++ b/node_modules/webworker-threads/test/test15_emit_ping_pong.js @@ -0,0 +1,31 @@ +var t= require('webworker-threads'); + +function eventHandler (data) { + ctr++; + this.emit('b', 0); +} + +function boot () { + thread.on('b', eventHandler); + + function eventHandler (data) { + thread.emit('a', 0); + } +} + +var ctr= 0; +var i= +process.argv[2] || 1; +console.log('Using '+ i+ ' threads'); + +var pool= t.createPool(i); +pool.all.eval(boot).all.eval('boot()').on('a', eventHandler).all.emit('b', 0).all.emit('b', 0).all.emit('b', 0); + + +var s= Date.now(); +function display () { + var e= Date.now()- s; + var ppps= (ctr*1e3/e).toFixed(1); + console.log("ping-pongs: "+ ctr+ ", ping-pongs-per-second: "+ ppps); +} + +setInterval(display, 1e3); -- cgit v1.2.3-70-g09d2