parallel

Runs an array of async functions with a concurrency limit. At most limit functions will be running at any time.

Available since v2.0.0

Import

import { parallel } from '@helpers4/promise';

Signature

parallel<T>(functions: readonly function[], limit: number): Promise<T[]>

Parameters

Parameter	Type	Description
functions	readonly function[]	Array of functions that return promises
limit	number	Maximum number of concurrent executions

Returns

Promise<T[]> — Promise that resolves with an array of results in the same order as the input

Examples

Run tasks with concurrency limit

Executes async functions with at most N running concurrently.

const results = await parallel(
  [() => fetch('/a'), () => fetch('/b'), () => fetch('/c')],
  2
)
// At most 2 requests run at a time; results are in order

Sequential execution with limit of 1

Setting limit to 1 runs functions one at a time.

await parallel([fnA, fnB, fnC], 1)
// Runs fnA, then fnB, then fnC

Source

View source on GitHub