blob: 3133fd103592a81e6b925ab75f78a31d7c343e3b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
var T= require('webworker-threads');
var i= process.argv[2] || 1;
console.log("Creating a pool of "+ i+ " threads");
var pool= T.createPool(i);
pool.all.eval('('+ ƒ+ ')()');
pool.on('myEvent', function myEventHandler (data) {
console.log("Received myEvent with data -> "+ data);
if (data === "QUIT") {
setTimeout(function () { pool.destroy() }, 1e3);
}
});
function ƒ () {
thread.on('myEvent', function cb (data) {
thread.emit('myEvent', data);
});
}
console.log("pool.any.emit('myEvent', 'POOL.ANY')");
pool.any.emit('myEvent', "POOL.ANY");
console.log("pool.all.emit('myEvent', 'POOL.ALL')");
pool.all.emit('myEvent', "POOL.ALL");
console.log("pool.any.emit('myEvent', 'QUIT')");
pool.any.emit('myEvent', "QUIT");
process.on('exit', function () {
console.log("BYE !");
});
|
