1 | var mod_fs = require('fs');
|
2 | var mod_vasync = require('../lib/vasync');
|
3 |
|
4 | var queue;
|
5 |
|
6 | function doneOne()
|
7 | {
|
8 | console.log('task completed; queue state:\n%s\n',
|
9 | JSON.stringify(queue, null, 4));
|
10 | }
|
11 |
|
12 | queue = mod_vasync.queue(mod_fs.stat, 2);
|
13 |
|
14 | console.log('initial queue state:\n%s\n', JSON.stringify(queue, null, 4));
|
15 |
|
16 | queue.push('/tmp/file1', doneOne);
|
17 | queue.push('/tmp/file2', doneOne);
|
18 | queue.push('/tmp/file3', doneOne);
|
19 | queue.push('/tmp/file4', doneOne);
|
20 |
|
21 | console.log('all tasks pushed:\n%s\n', JSON.stringify(queue, null, 4));
|