23

async.series 和 async.parallel 有什么区别。考虑以下示例,我得到了相同的结果。

async.parallel([
    function(callback){
        setTimeout(function(){
            callback(null, 'one');
        }, 200);
    },
    function(callback){
        setTimeout(function(){
            callback(null, 'two');
        }, 100);
    },
    function(callback){
        setTimeout(function(){
            var err = new Error('I am the error');
            callback(err);
        }, 400);
    },
    function(callback){
        setTimeout(function(){
            callback(null, 'three');
        }, 600);
    },
],
// optional callback
function(err, results){
    if(err){
        console.log('Error');
    } else {

    }
    console.log(results);
    //results is now equal to [ 'one', 'two', undefined ]
    // the second function had a shorter timeout.
});

async.series([
   function(callback){
        setTimeout(function(){
            callback(null, 'one');
        }, 200);
    },
    function(callback){
        setTimeout(function(){
            callback(null, 'two');
        }, 100);
    },
    function(callback){
        setTimeout(function(){
            var err = new Error('I am the error');
            callback(err);
        }, 400);
    },
    function(callback){
        setTimeout(function(){
            callback(null, 'three');
        }, 600);
    }
],
// optional callback
function(err, results){
    //results is now equal to [ 'one', 'two', undefined ]
    if(err){
        console.log('Error');
    } else {

    }
    console.log(results);
});

我看不出有什么区别。也许我的样品不好?我在 github async 存储库上阅读了关于这两个函数的文档,你可以找到 async.parallel 函数:

如果任何函数将错误传递给其回调,则会立即使用错误值调用主回调

async.parallel 中的主要回调是什么?

4

2 回答 2

42

async.series串行调用您的函数(等待前一个函数完成,然后再开始下一个函数)。async.parallel将同时启动它们(或者无论如何在单线程土地上同时启动它们)。

主回调是在调用async.parallelor时可选提供的async.series(签名是async.parallel(tasks, [callback])

所以实际发生的是这样的:

平行:

  • parallel启动所有任务,然后等待
  • 所有四个任务都安排了超时
  • timeout 100 触发,添加其结果(结果为 now [ , "Two"]
  • timeout 200 触发,添加其结果(结果为 now ["One", "Two"]
  • timeout 400 触发,返回错误并undefined作为结果(结果为 now ["One", "Two", undefined]
  • parallel注意到一个错误,立即返回它到目前为止收到的结果
  • timeout 600 触发,但没人关心返回结果

系列:

  • series触发第一个任务;它安排它的超时。
  • series等到 200 毫秒后调用回调,然后添加结果。(结果现在["One"]
  • series触发第二个任务;它安排它的超时。
  • series等到 100 毫秒后调用回调,然后添加结果。(结果现在["One", "Two"]
  • series触发第三个任务;它安排它的超时。
  • series等待 400 毫秒后调用回调,然后添加结果并因错误退出。(结果现在["One", "Two", undefined]
  • 第四个任务永远不会执行,也永远不会安排它的超时时间。

您获得相同结果的事实是由于您setTimeout在任务中依赖的事实。

至于如何parallel有用,请尝试下载一百个网页parallel;然后对series. 走着瞧吧。

于 2013-07-25T08:48:07.537 回答
9

正如您在文档中看到的:

  • 对于 async.series :

依次运行一系列函数,每个函数在前一个函数完成后运行。

这意味着异步将在调用“n+1”之前等待“n”函数结束。

  • 对于异步并行

并行运行一组函数,无需等到前一个函数完成。

但是你的代码太简单了,看不出区别。如果它们都适合你,你应该选择 async.parallel 它更快。

于 2013-07-25T09:11:05.323 回答