@shogo82148/limit-concurrency

limit_concurrency

It runs the tasks in parallel but ensures that at any given time, no more than the specified limit of tasks are being executed concurrently. Once a task completes, another task (if any remain) is started, maintaining the concurrency limit until all tasks have been executed.

import { limitConcurrency } from "./limit-concurrency.ts";

function* taskGenerator(): Generator<() => Promise<void>> {
    for (let i = 0; i < 10; i++) {
        yield async () => {
            // Simulate an asynchronous task
            console.log(`Task ${i} started`);
            await new Promise((resolve) => setTimeout(resolve, 1000));
            console.log(`Task ${i} finished`);
        };
    }
}

const iterator = taskGenerator();
limitConcurrency(iterator, 2); // Limit concurrency to 2