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)