1 | var mod_vasync = require('../lib/vasync');
|
2 |
|
3 | var barrier = mod_vasync.barrier();
|
4 |
|
5 | barrier.on('drain', function () {
|
6 | console.log('barrier drained!');
|
7 | });
|
8 |
|
9 | console.log('barrier', barrier);
|
10 |
|
11 | barrier.start('op1');
|
12 | console.log('op1 started', barrier);
|
13 |
|
14 | barrier.start('op2');
|
15 | console.log('op2 started', barrier);
|
16 |
|
17 | barrier.done('op2');
|
18 | console.log('op2 done', barrier);
|
19 |
|
20 | barrier.done('op1');
|
21 | console.log('op1 done', barrier);
|
22 |
|
23 | barrier.start('op3');
|
24 | console.log('op3 started');
|
25 |
|
26 | setTimeout(function () {
|
27 | barrier.done('op3');
|
28 | console.log('op3 done');
|
29 | }, 10);
|