#!/usr/bin/env node | |
var assert = require('assert'); | |
var qjob = require('../qjobs'); | |
// only 2 jobs in the same time | |
var q = new qjob({maxConcurrency:2}); | |
var testExecutedJobs = 0; | |
var myjob = function(args,next) { | |
setTimeout(function() { | |
testExecutedJobs++; | |
next(); | |
},50); | |
} | |
// Let's add 10 job and add them to the queue | |
for (var i = 0; i<10; i++) { | |
q.add(myjob,['test'+i]); | |
} | |
q.on('end',function() { | |
assert.equal(testExecutedJobs, 10); | |
}); | |
q.run(); | |