TS promises processing pool

index.ts

const processInPool = async (
    tasks: (() => Promise<unknown>)[],
    poolSize: number,
) => {
    const pool = tasks.toReversed();
    const worker = async () => {
        while (true) {
            const task = pool.pop();
            if (task == null) {
                return;
            }
            await task();
        }
    };

    const workers = Array.from({ length: poolSize }, () => worker());
    return Promise.allSettled(workers);
};

// Test
const action = (id: number) => {
    const { promise, resolve } = Promise.withResolvers();
    console.log("action", id);
    setTimeout(resolve, 2000 * Math.random());
    return promise;
};
const tasks = Array.from({ length: 100 }, (_, i) => () => action(i));
processInPool(tasks, 10);