函数完成时Nodejs回调下一个循环

Question

假设我们有一个脚本将为数组中的每一行执行特定任务。

function execute(err, array){
    loop(array, function(err,object){
         console.log(object)
         //do a certain task when it's finished get into the next object successively.
    });
}

function loop(array,callback){
    array.forEach(function(object){
         callback(null, object);
    });
}

function array(callback){
     callback(null, [1, 2, 3, 4, 5]);
}

setTimeout(function(){
    array(execute); 
}, 6000);

问题：

• 如何完成任务才进入下一个循环？
• 我的函数被认为是异步的吗？

Answer 1

你可以做这样的事情来迭代你的数组：

var myarray = [1,2,3,4,5];
next(myarray, 0);

function next(array, idx) {
    if (idx !== array.length) {
        // do something
        console.log(array[idx]);

        // run other functions with callback
        another_fct(array[idx], function() {
            next(array, idx + 1); // then the next loop
        });

        // or run directly the next loop
        next(array, idx + 1);
     } else {
        // the entire array has been proceed
        console.log('an array of '+array.length+' number of elements have been proceed');
    }
}

function another_fct(array_element, callback) {
    // do something with array_element
    console.log('value : '+array_element);
    callback(); // run the next loop after processing
}

此方法将同步执行您的数组元素。

Answer 2

试试这个：

function execute(err, array) {
    loop(array, function(err, object, next) {
         console.log(object);
         next(); // this will call recur inside loop function
    }, function() {
         console.log('All done');
    });
}

function loop(array, callback, finish) {
    var copy = array.slice();
    (function recur() {
        var item = copy.shift();
        if (item) {
            callback(null, item, recur);
        } else {
            if (typeof finish == 'function') { 
                finish();
            }
        }
    })();
}

不，您的函数不是异步的，而是使用 setTimeout 异步调用它。

Answer 3

async 为此提供了 async.series 和其他帮助程序。

Answer 4

如果您重构代码并删除任何多余的匿名函数，您可以更好地理解它。情况是，将匿名函数作为参数传递给另一个函数还没有使函数异步。您在"Does taking a callback make a function asynchronous?" 中阅读了更多更深入的解释。

从重构版本开始，

setTimeout(function() {
    [1, 2, 3, 4, 5].forEach(function(object) {
        console.log(object)
        //do a certain task when it's...
    });
}, 6000);

可以看出，数组调用了forEach。 forEach 方法对每个数组元素执行一次提供的函数并同步执行。

所以，回答你的问题：

1. 是的，它仅在完成前一项后才调用下一项（但如果执行任何异步操作，请参见下文）
2. 这不被认为是异步的，因为它不执行任何异步操作（不考虑外部setTimeout）

但是，如果您选择在forEach 函数中启动异步 操作，那么情况就会发生很大变化。结果是所有操作同时进行。这在资源方面是潜在的危险操作。有诸如 async 之类的库可以优雅地处理这个用例。

（顺便说一句，很好地使用 Node.js errbacks，其中第一个函数参数保留用于传递潜在错误。）