spigot

var Spigot = require('spigot')
  , concurrency = 2 // process 2 jobs at a time (at most)
 
var spigot = new Spigot(concurrency, function(job, done) {
  console.log(job);
  done();
});
 
spigot.on('error', function(err, job) {
  console.log('oh noes, error ' + err + ' with job ' + job);
});
 
spigot.on('empty', function() {
  console.log('all done');
});
 
spigot.on('done', function(job) {
  console.log('finished job ' + job);
});
 
for (var i = 0; i < 100; ++i) {
  spigot.queue('meow ' + i);
}