array-async-queue

Install

npm install array-async-queue

About

Asynchronously go through an array with concurrency and queue

Example

const arrayAsyncQueue = require("array-async-queue");
const arr = [];
const concurrency = 10;

for (let i = 0; i < 1000; i++) {
  arr.push(i);
}

function getRandomInt(min, max) {
  return Math.floor(Math.random() * (max - min)) + min;
}

arrayAsyncQueue(arr, concurrency, (val, stop) => {
  console.log(val);

  if(getRandomInt(0, 100) >= 99) {
    // stop the queue if necessary
    return stop();
  }

  return new Promise(resolve => setTimeout(resolve, getRandomInt(0, 50))
})

Description

Initially, the functions will be launched in parallel in the quantity specified in the variable concurrency. After completing one of them, the next one remaining in the array will be called. At the same time, the number of parallel called functions is always equal to concurrency.