first commit

wangzhibo

2026-05-09 53418655c061ac26f66058253f39200aced1ab1d

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