var Throttler = require('throttler');
 
var throttler = new Throttler({
    'maxActive' : 50,
    'wait' : 2500
});
 
for (var i = 0; i < 1000; i++) {
    throttler.add(function(callback) {
        // do some work
        callback(some, results);
    });
}
 
throttler.on('job-started', function(stats) {
    console.log('Job started. Current stats: %j', stats);
}).on('job-completed', function(stats) {
    console.log('Job completed. Current stats: %j', stats);
}).on('complete', function(stats) {
    console.log('All jobs complete. Final stats: %j', stats);
});

{
    'maxActive' : 50,	// The maximum number of jobs to run at once. Must be specified
    'wait' : 2500 		// The time, in milliseconds, to wait before trying to run more jobs if maxActive jobs are currently running
}

{
    "active" : 2,					// The number of actively running jobs
    "pending" : 16,					// The number of pending jobs
    "complete" : 4,					// The number of completed jobs
    "averageRunTime" : 1756.5,		// The current average for how long each job takes to complete, in milliseconds
    "job" : {
        "identifier" : "Job #6",	// A system-generated job identifer
        "startTime" : 1363294870424	// The time the job was started
    }
}

{
    "active" : 4,
    "pending" : 15,
    "complete" : 5,
    "averageRunTime" : 2002,
    "job" : {
        "identifier" : "Job #4",
        "startTime" : 1363294867922,
        "completedResults" : ["some","results"],	// The args passed to the callback when the job completed
        "elapsed" : 2984,							// The elapsed time to run the job, in milliseconds
        "complete" : true							// Did the job complete, will always be true here
    }
}

{
    "active" : 0,
    "pending" : 0,
    "complete" : 20,
    "averageRunTime" : 1678.9
}