Summary

Concurrent workers is to eliminate memory limitations on large request handlings from Promise.all or Promise.allSettled And also elimiate waiting time on batch process.

Usage

You can import class by import { Runner } from "concurrent-workers"

Runner class takes 3 parameters new Runner(tasks, number_of_workers, timeout)

• tasks an array of functions that executes the task
• number_of_workers number of works to create, integer. Default = 3
• timeout ms, setting timeout on each task to avoid hanging onto one task for a long time. Default = 0

Eg.

  import { Runner } from "concurrent-workers"

  ...
  const tasks = [
    () => new Promise((resolve) => setTimeout(() => resolve(
      "bbb"
    ), 40000)),
    () => new Promise((resolve) => setTimeout(() => resolve(
        "ccc"
    ), 2000)),
    () => new Promise((resolve) => setTimeout(() => resolve(
        "ddd"
    ), 10000))
  ]
  const testC = new Runner(tasks, 10, 1000);
  const result = await testC.execute();