1 |
|
2 |
|
3 | var Threads= require('../');
|
4 |
|
5 | function cb (err, msg) {
|
6 | i++;
|
7 | ƒ();
|
8 |
|
9 | }
|
10 |
|
11 |
|
12 | function ƒ () { process.nextTick(cb) }
|
13 |
|
14 | var i= +process.argv[2] || 1;
|
15 | console.log('Using '+ i+ ' threads');
|
16 |
|
17 | var threads= [];
|
18 | while (i--) {
|
19 | ƒ();
|
20 | }
|
21 |
|
22 | i= 0;
|
23 | var t= Date.now();
|
24 | function display () {
|
25 | var e= Date.now()- t;
|
26 | var tps= (i*1e3/e).toFixed(1);
|
27 | process.stdout.write('\nt (ms) -> '+ e+ ', i -> '+ i+ ', tps -> '+ tps+ ', [ '+ threads.map(percent)+ ' ]');
|
28 | function percent (v) {
|
29 | return Math.round(v/i*100);
|
30 | }
|
31 | }
|
32 |
|
33 |
|
34 |
|
35 | setInterval(display, 1e3);
|