asyncqueue.js

var async = require('async');

// Send email
var sendEmail = function(email,callback) {
  console.log("Sending email to "+email);
  callback(null);
}

// create a queue object with concurrency 2
var q = async.queue(sendEmail,2);

// Called when every processing is done
q.drain = function() {
    console.log('all emails sent');
}

// add some emails to the queue
q.push(["[email protected]","[email protected]"]);

// add email to the front of the queue
q.unshift("[email protected]");

//output
/*
Sending email to [email protected]
Sending email to [email protected]
Sending email to [email protected]
all emails sent
*/