Node JS Promise.all и forEach

Ответ 1

Это довольно просто с некоторыми простыми правилами:

• Всякий раз, когда вы создаете обещание в then, верните его - любое обещание, которое вы не вернете, не будет ожидать снаружи.
• Всякий раз, когда вы создаете несколько promises, .all их - таким образом, он ожидает, что все promises и ни одна из них не отключена.
• Всякий раз, когда вы в гнезде then s, обычно можете вернуться в середине - then. Цепочки обычно не более 1 уровня.
• Всякий раз, когда вы выполняете IO, это должно быть с обещанием - либо оно должно быть обещано, либо должно использовать обещание сообщить о его завершении.

И некоторые советы:

• Отображение лучше выполняется с помощью .map, чем с for/push - если вы сопоставляете значения с помощью функции, map позволяет кратко выразить понятие применения действий один за другим и агрегирование результатов.
• Concurrency лучше, чем последовательное выполнение, если он свободен - лучше выполнять действия одновременно и ждать их Promise.all, чем выполнять вещи один за другим - каждый из них ждет до следующего.

Итак, давайте начнем:

var items = [1, 2, 3, 4, 5];
var fn = function asyncMultiplyBy2(v){ // sample async action
    return new Promise(resolve => setTimeout(() => resolve(v * 2), 100));
};
// map over forEach since it returns

var actions = items.map(fn); // run the function over all items

// we now have a promises array and we want to wait for it

var results = Promise.all(actions); // pass array of promises

results.then(data => // or just .then(console.log)
    console.log(data) // [2, 4, 6, 8, 10]
);

// we can nest this of course, as I said, `then` chains:

var res2 = Promise.all([1, 2, 3, 4, 5].map(fn)).then(
    data => Promise.all(data.map(fn))
).then(function(data){
    // the next `then` is executed after the promise has returned from the previous
    // `then` fulfilled, in this case it an aggregate promise because of 
    // the `.all` 
    return Promise.all(data.map(fn));
}).then(function(data){
    // just for good measure
    return Promise.all(data.map(fn));
});

// now to get the results:

res2.then(function(data){
    console.log(data); // [16, 32, 48, 64, 80]
});

Ответ 2

Вот простой пример, использующий сокращение. Он работает серийно, поддерживает порядок вставки и не требует Bluebird.

/**
 * 
 * @param items An array of items.
 * @param fn A function that accepts an item from the array and returns a promise.
 * @returns {Promise}
 */
function forEachPromise(items, fn) {
    return items.reduce(function (promise, item) {
        return promise.then(function () {
            return fn(item);
        });
    }, Promise.resolve());
}

И используйте его следующим образом:

var items = ['a', 'b', 'c'];

function logItem(item) {
    return new Promise((resolve, reject) => {
        process.nextTick(() => {
            console.log(item);
            resolve();
        })
    });
}

forEachPromise(items, logItem).then(() => {
    console.log('done');
});

Мы посчитали полезным отправить необязательный контекст в цикл. Контекст является необязательным и разделяется всеми итерациями.

function forEachPromise(items, fn, context) {
    return items.reduce(function (promise, item) {
        return promise.then(function () {
            return fn(item, context);
        });
    }, Promise.resolve());
}

Ваша функция обещания будет выглядеть так:

function logItem(item, context) {
    return new Promise((resolve, reject) => {
        process.nextTick(() => {
            console.log(item);
            context.itemCount++;
            resolve();
        })
    });
}

Ответ 3

У меня была такая же ситуация. Я решил использовать два Promise.All().

Я думаю, что это действительно хорошее решение, поэтому я опубликовал его на npm: https://www.npmjs.com/package/promise-foreach

Я думаю, что ваш код будет чем-то вроде этого

var promiseForeach = require('promise-foreach')
var jsonItems = [];
promiseForeach.each(jsonItems,
    [function (jsonItems){
        return new Promise(function(resolve, reject){
            if(jsonItems.type === 'file'){
                jsonItems.getFile().then(function(file){ //or promise.all?
                    resolve(file.getSize())
                })
            }
        })
    }],
    function (result, current) {
        return {
            type: current.type,
            size: jsonItems.result[0]
        }
    },
    function (err, newList) {
        if (err) {
            console.error(err)
            return;
        }
        console.log('new jsonItems : ', newList)
    })