node_modules/webworker-threads/test/test29_puts_callback_loop.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14

var i= parseInt(process.argv[2], 10) || 2;
var pool= require('webworker-threads').createPool(i);
console.log("Using "+ i+ " threads.");

function ƒ () {
  puts(" ["+ thread.id+ "]"+ (++i));
  //if (!(i%1e3)) gc();
}

function callback (err, data) {
  this.eval('ƒ()', callback);
}

pool.all.eval('i=0').all.eval(ƒ).all.eval('ƒ()', callback);