queue

Task (function) queue with concurrency / timeout control.

This is a fork of tj/node-queue3

I was doing maintenance on some libraries and ran into vulnerabilities reported by npm because of old versions of dependencies in queue3.

This fork:
- bumps versions of debug and superagent
- migrates the tests to tape for simplicity and ease of debugging
- updates the example to work with the new superagent api
- removes the Makefile - to run tests do npm test

There have been no changes to the module code in index.js.

- The version number in pacakage.json was bumped to 1.0.4 since the original queue3 on npm reports 1.0.3.
- July 13, 2019: bumped to 1.0.5 with updated deps and example, and CI
- Feb 16, 2020: bumped to 1.0.6 with updated deps and CI on github
- Apr 25, 2020: bumped to 1.0.7 with updated deps
- Jul 26, 2020: bumped to 1.0.8 with updated deps
- Nov 8, 2020: bumped to 1.0.9 with updated deps
- Jan 16, 2022: bumped to 1.0.10 with updated deps
- Sep 1, 2024: bumped to 1.1.0 with updated deps

Installation

$ npm install queue4

Example

``js

var request = require('superagent');
var Queue = require('./');
var q = new Queue({ concurrency: 3, timeout: 1000 });

var urls = [
'https://google.com',
'https://yahoo.com',
'https://ign.com',
'https://msn.com',
'https://hotmail.com',
'https://cloudup.com',
'https://learnboost.com'
];

var id = setInterval(function(){
urls.forEach(function(url){
q.push(function(fn){
console.log('%s', url);
request.get(url, function(err, res){
console.log('%s -> %s %s',
url,
(res && res.status) || 'no response',
(err && err.message) || 'OK');
fn();
});
});
});
}, 5000);

var tid = setInterval(function(){
console.log('%s queued', q.length);
}, 1000);

setTimeout(function(){
console.log('shutting down');
clearInterval(id);
clearInterval(tid);
}, 15000);
``

License

MIT