@pdz/queue

Simple way to run any functions in queue, with pauses between jobs and/or waiting timeouts.

Example:

'use strict';

const pdzQ = require('@pdz/queue');

const log = (...args) => {
	console.log.apply(null, [parseFloat(Date.now() / 1000).toFixed(1)].concat(args));
}

const q = new pdzQ({
	pause: 100, // Pause between jobs
	wait: 5000, // Wait for job execution
	timeout: 5000, // Additional timeout if wait is exceed but job is already runned
});

q.job(() => 'Job 1 - ok').then(log).catch(e => log(e.message));
q.job(() => 'Job 2 - ok').then(log).catch(e => log(e.message));
q.job(() => 'Job 3 - ok').then(log).catch(e => log(e.message));
q.job(() => 'Job 4 - ok').then(log).catch(e => log(e.message));
q.job(async () => {
	await new Promise(pres => setTimeout(pres, 1000));
	return 'Job 5 - ok';
}).then(log).catch(e => log(e.message));
q.job(async () => {
	await new Promise(pres => setTimeout(pres, 10000));
	return 'Job 6 - ok';
}).then(log).catch(e => log('Job 6 - error:', e.message)); // Timeout exceed
q.job(async () => {
	await new Promise(pres => setTimeout(pres, 10000));
	return 'Job 7 - ok';
}).then(log).catch(e => log('Job 7 - error:', e.message)); // Wait exceed

const testJob8 = async (...args) => {
	await new Promise(pres => setTimeout(pres, 10000));
	return 'Job 8 - ok with params: [' + args.join(',') + ']';
}

q.with({wait: 30000, timeout: 20000}).job(testJob8, null, 'Param1', 'Param2').then(log).catch(e => log(e.message)); // No exceed

q.job(async () => {
	await new Promise(pres => setTimeout(pres, 10000));
	return 'Job 9 - ok';
}).then(log).catch(e => log('Job 9 - error:', e.message)); // Wait exceed

// 1636035384.2 Job 1 - ok
// 1636035384.3 Job 2 - ok
// 1636035384.4 Job 3 - ok
// 1636035384.5 Job 4 - ok
// 1636035385.6 Job 5 - ok
// 1636035389.2 Job 7 - error: Wait for job execution timeout exceed
// 1636035389.2 Job 9 - error: Wait for job execution timeout exceed
// 1636035394.2 Job 6 - error: Job execution timeout exceed
// 1636035405.8 Job 8 - ok with params: [Param1,Param2]