queuer

Introduction

This is a simple queueing mechanism. It uses interval to check remaining items in the queue. Uses es2015 syntaxes.

Installation

$ npm install --save simple-queuer;

Usage: basic

// import the class
import Queuer from 'simple-queuer';

// instantiate
var queuer = new Queuer(10); // the default value is 10.

// add tasks. this will automatically start the queue.
queuer.push(
	function(next){
		setTimeout(()=>{next()}, 1000);
	}
);

Usage: async with promise

"use strict";

// import the class
import Queuer from 'simple-queuer';

// instantiate
var queuer = new Queuer(10); // the default value is 10.

function getRandomTimer(){
	return new Promise( (resolve, reject) => {
		let timer = (next) => {
			setTimeout(()=>{
				console.log('timer '+i+' done!')
				resolve(i);
			}, Math.random()*1000);
		}
		queuer.push(timer);
	});
}

// let's create 100 random timers
var promises = [];
for(var i=0; i< 100; i++){
	promises.push(getRandomTimer());
}
Promise
	.all(promises)
	.then((results) => {
		console.log('all timers done!');
	})
;