concurrent-queue

A priority queue with configurable retry and concurrency

Table of Contents

• Install
• Usage
• Options
• Contributors
• License

Install

npm:

npm install smart-cq

yarn:

yarn add smart-cq

Usage

const CQueue = require('smart-cq');

const cqueue = new CQueue({
  concurrency: 10,
  retries: 3
});

const asyncTask = () => {
  return new Promise((resolve, reject) => {
    setTimeout(() => {
      resolve();
    }, 1000);
  });
}

cqueue.enqueue(asyncTask)

Options

• concurrency - (default: Infinity) - concurrent tasks to run
• retries - (default: 3) - retry attempts on failed tasks

Contributors

License

MIT © Shaun Warman