A simple promise-based job queue with concurrency.
Example:
// import { Queue } from '@ars9/easy-queue'); /* Correct Typescript import */
const { Queue } = require('@ars9/easy-queue');
// Create a queue instance with concurrency 3
const q = new Queue(3);
// Add some jobs to queue
q.enqueue(() => console.log(`I'm doing my part`));
q.enqueue(() => console.log(`Thanks me too`));
q.enqueue(() => console.log(`And my axe!`));
// By default, exceptions are handled, but silenced. You can attach a custom handler.
q.onError((error) => console.error(error));
// Start execution. This method will be implicitly called in `wait` if omitted.
q.start();
// Wait for execution. Starts queue if needed.
q.wait().then(() => console.log(`Done`));
// Console output:
/*
I'm doing my part
Thanks me too
And my axe!
Done
*/