quu is a simple and lightweigt function queue.
Create an instance of quu. Run <int> concurrency tasks at once, <bool> wait for run() to be called before starting tasks.
Add a task to the queue. Call done() when the task is done any err will be collected.
complete will be called, when all tasks are completed, with all errors collected.
var quu = require("quu");
// create queue with a maximum concurrency of 5
var q = quu(5);
// add a task to the queue
q.push(function(done){
// let's do heaps of async stuff...
// look at all the stuff we are doing...
// nearly finished... done.
// phew! that was quite some work.
// ok, lets wrap this up now!
done();
});
q.run(function(errs){
if (errs) err.forEach(console.error);
// queue is empty
});