Выполнение N async параллельных скриптов, с лимитом и ожиданием их выполнения

[b5414]

Всем привет, не могу решить задачу, nodejs, сижу 3 день... Задача сложна, и мне слов не хватает описать её, связи с этим представляю несколько описаний

Суть задачи:
Нужно запустить asd - N раз, параллельно и с лимитом.
Если одна из N завершилась, смотреть лимит, запускать asd до лимита опять. Ждать ответ из asd, добавлять его в пелеменную... и вся эта махинация до окончания массива который передается в asd.

:

const Asd=async(a)=>{
	let b = await some(a);
	return b;
};

Или так, НО без await на 14 строке, а т.е. параллельное выполнение и ожидания ответов так же параллельно от каждой, исполнение до конца массива с лимитом в 4(например)

const asd=async(a)=>{
	return a*2;
};

const main=async()=>{
	let URL = [1,2,3,4,5];
	let x = [];
	let k = 0;
	let limit = 4;
	
	while(URL.length > 0){
		while(k < limit && URL.length > 0){
			k++;
			let g = await asd(URL.shift()).then((r)=>{
				k--;
				return r;
			});
			x.push(g.toString());
		}
	}
	
	return x;
};

const a=async()=>{
	let x = await main();
	console.log(x);
};
a();

Или так: Нужно открыть браузер, открыть в нем 4 вкладки из массива ЮРЛ, как только работа в одной из вкладок проделана(из asd return b) и вкладка закрылась, если ЮРЛ.length > 0 запускать еще вкладку до лимита 4

Или так: Есть работающий код, который запускает asd(в котором парсится страница, он асинхронен и в нём присутствует await), код ожидает ответа от asd, затем запускает asd заново, покуда URL лист не иссякнет, после окончания массива выдает общий результат asd(часть всех страниц). Дак вот, как запускать asd параллельно N раз, с лимитом N в K(4 asd максимум)

[Alexandroppolus]

см. в консольку

function run(limit, func, params) {
    'use strict';
    if (typeof limit !== 'number' || limit < 1 || typeof func !== 'function' || !params || !params.length) {
        return Promise.resolve([]);
    }

    return new Promise(function (resolve) {
        var result = new Array(params.length);
        var pos = 0;
        var rcount = 0;
        function ok(data) {
            end(this, false, data);
        }
        function err(data) {
            end(this, true, data);
        }
        function end(idx, error, data) {
            result[idx] = {
                data: error ? null : data,
                error: error ? data : null
            };
            rcount++;
            if (pos < params.length) {
                Promise.resolve(func(params[pos])).then(ok.bind(pos), err.bind(pos));
                ++pos;
            } else {
                if (rcount >= params.length) {
                    resolve(result);
                }
            }
        }
        var m = Math.min(limit, params.length);
        while (pos < m) {
            Promise.resolve(func(params[pos])).then(ok.bind(pos), err.bind(pos));
            ++pos;
        }
    });
}


run(3, function(p) {
    console.log('start: ', p);
    return new Promise(function(r) { setTimeout(function(v) { console.log(v); r(v); }, p * 1000, 'result ' + p); });
}, [5, 3, 7, 2, 6]).then(console.log);

[SuperZen]

Велосипеды кругом )
https://github.com/sindresorhus/p-limit
https://github.com/sindresorhus/p-queue

[b5414]

https://github.com/sindresorhus/p-limit
https://github.com/sindresorhus/p-queue

Пушечка, спасибо, это то что нужно <3