javascript – 在系列中执行Promise.all

2023年4月26日 213次阅读

我有一个包含promises数组的数组,每个内部数组可以有4k,2k或500个promise.

总共有大约60k的承诺,我也可以用其他值来测试它.

现在我需要执行Promise.all(BigArray [0]).

一旦第一个内部数组完成,我需要执行下一个Promise.all(BigArray [1])等等等等.

如果我尝试执行Promise.all(BigArray)它的抛出：

fatal error call_and_retry_2 allocation failed – process out of memory

我需要按顺序执行每个promises,而不是并行执行它,我认为这就是Node正在做的事情.
我不应该使用新的库,但我愿意考虑答案！

编辑：

这是一段代码示例：

function getInfoForEveryInnerArgument(InnerArray) {
    const CPTPromises = _.map(InnerArray, (argument) => getDBInfo(argument));
    return Promise.all(CPTPromises)
        .then((results) => {
            return doSomethingWithResults(results);
        });
}
function mainFunction() {
    BigArray = [[argument1, argument2, argument3, argument4], [argument5, argument6, argument7, argument8], ....];
    //the summ of all arguments is over 60k...
    const promiseArrayCombination = _.map(BigArray, (InnerArray, key) => getInfoForEveryInnerArgument(InnerArray));

    Promise.all(promiseArrayCombination).then((fullResults) => {
        console.log(fullResults);
        return fullResults;
    })
}

最佳答案 Promise.all不起作用,您可以使用Array.reduce逐个处理BigArray元素：

BigArray.reduce((promiseChain, currentArray) => {
    return promiseChain.then(chainResults =>
        Promise.all(currentArray).then(currentResult =>
            [...chainResults, currentResult]
        )
    );
}, Promise.resolve([])).then(arrayOfArraysOfResults => {
    // Do something with all results
});
点赞