BrenoAlberto

export async function concurrentTaskQueue<T>(asyncFunctions: Array<() => Promise<T>>, maxConcurrent: number): Promise<T[]> {
    let currentIndex = 0;
    const runningFunctions = new Set<Promise<T>>();
    const orderedRunnedFunctions: Map<Promise<T>, number> = new Map();
    let results: Array<T> = Array(asyncFunctions.length);
    while (currentIndex < asyncFunctions.length) {
        while (runningFunctions.size < maxConcurrent && currentIndex < asyncFunctions.length) {
            const asyncFunction = asyncFunctions[currentIndex];
            const promise = asyncFunction().finally(() => {
                runningFunctions.delete(promise);