nodejs流程控制之async

本文主要讲解async的函数: series,parallel, waterfall 函数的理解和 使用

async 函数是什么?

一句话,async 函数就是 Generator 函数的语法糖。

背景:
Node.js 使用事件驱动,非阻塞I/O 模型而得以轻量和高效。
事件发生后交由指定的程序处理,处理完成后就调用事件回调函数。回调机制使用Node.js具有了强大的并发处理能力,但也带来了一系列的回调嵌套问题。

async解决了什么问题?

解决回调嵌套的方法有很多,如:async、promise、事件发射器等。几种方案多少都使用过,今天介绍一下async中的常用方法。本篇主要介绍其流程控制部分。

async 提供的api包括三个部分::

  • 流程控制
  • 集合处理
  • 工具

流程控制常用的方法有:

series、parallel、waterfall、whilst、auto等。

这些方法功能如下:

  • series:多个任务依次执行
  • parallel:多个任务并发执行
  • waterfall:多个任务依次执行,上一任务的输出可做为下一任务的输入参数
  • whilst:while循环执行任务,但本次任务执行完毕后才会进入下一次循环
  • auto:根据任务需要选择顺序或并发执行任务

下面重点介绍series、parallel、waterfall:

安装方法: npm install async
使用方法: var async=require('async');

1.Async.series(tasks, [callback])

  • 用法:

series方法用于依次执行(串行执行)多个方法
一个方法执行完毕后才会进入下一方法
方法之间没有数据传递

  • 参数
    • tasks:需要执行多个方法。tasks可以以数组形式传入,也可以以object对象形式传入。参数类型不同,影响的是返回数据的格式。每个方法都要一个回调方法
  • callback(err, result),用于处理错误或进入下一方法。当发生错误时(即:err参数存在时),其后的方法会跳过,错误被传入最终回调方法中。
    callback(err, results):可选的最终回调方法。出错时,tasks中抛出的错误将在此方法中捕获,错误被传入err参数。不出错时,tasks中回调结果将被写入results参数中,以数据或对象形式提供。
  • 实例
var async = require('async');
//以数组形式传入需要执行的多个方法
async.series([
    function(callback){
        // 执行一些操作后,callback进入下一方法
        callback(null, 'one');
    },
    function(callback){
        // 执行一些操作后,callback进入可选的最终回调方法
        callback(null, 'two');
    }
],
// 可选的最终回调 
function(err, results){
    // 当tasks中的任一方法发生错误,即回调形式为callback('错误信息')时,错误将被传递给err参数,未发生错误err参数为空
    // results中为数组中两个方法的结果数组:['one', 'two'] 
});
 


//以object对象形式传入需要执行的多个方法
async.series({
    one: function(callback){
        // 执行一些操作后,callback进入下一方法
        callback(null, 1);
    },
    two: function(callback){
        // 执行一些操作后,callback进入可选的最终回调方法
        callback(null, 2);
    }
},
function(err, results) {
    // 当tasks中的任一方法发生错误,即回调形式为callback('错误信息')时,错误将被传递给err参数,未发生错误err参数为空
    // results中为数组中两个方法的结果对象:{one: 1, two: 2} 
});

该函数的详细解释为

  1. 依次执行一个函数数组中的每个函数,每一个函数执行完成之后才能执行下一个函数。
  2. 如果任何一个函数向它的回调函数中传了一个error,则后面的函数都不会被执行,并且将会立刻会将该error以及已经执行了的函数的结果,传给series中最后那个callback。
  3. 当所有的函数执行完后(没有出错),则会把每个函数传给其回调函数的结果合并为一个数组,传给series最后的那个callback。
  4. 还可以json的形式来提供tasks。每一个属性都会被当作函数来执行,并且结果也会以json形式传给series最后的那个callback。这种方式可读性更高一些。
  • 需要注意的是:
  • 如果中间某个函数出错,series函数如何处理

  • 思考一下:如果某个函数传给回调的值为undefined, null, {}, []等,series如何处理

另外还需要注意的是:多个series调用之间是不分先后的,因为series本身也是异步调用。

2. parallel(tasks, [callback])

  • 执行原理

parallel方法用于 并行执行 多个方法,所有传入的方法都是立即执行,方法之间没有数据传递。传递给最终callback的数组中的数据按照tasks中声明的顺序,而不是执行完成的顺序。

  • 参数
  • ** tasks:需要执行多个方法。tasks可以以 *** 数组形式传入,也可以以object对象*形式传入。和series函数一样,tasks参数类型不同,返回的results格式会不一样。
    每个方法都要一个回调方法callback(err, result),回调方法需要提供一个err参数或是result参数。

当如果某个函数出错,则立刻将err和已经执行完的函数的结果值传给parallel最终的callback。其它未执行完的函数的值不会传到最终数据,但要占个位置。

  • callback(err, results):可选的最终回调方法。出错时,tasks中抛出的错误将在此方法中捕获,错误被传入err参数。不出错时,tasks中回调结果将被写入results参数中,以数据或对象形式提供。
  • 示例
 //以数组形式传入需要执行的多个方法
async.parallel([
    function(callback){
        // 执行一些操作后,callback表示本方法执行完成
        callback(null, 'one');
    },
    function(callback){
        // 执行一些操作后,callback表示本方法执行完成
        callback(null, 'two');
    }
],
// 可选的最终回调 
function(err, results){
    // 当tasks中的任一方法发生错误,即回调形式为callback('错误信息')时,错误将被传递给err参数,未发生错误err参数为空
    // results中为数组中两个方法的结果数组:['one', 'two'] ,即使第二个方法先执行完成,其结果也是在第一个方法结果之后
});
 
//以object对象形式传入需要执行的多个方法
async.parallel({
    one: function(callback){
        // 执行一些操作后,callback表示本方法执行完成
        callback(null, 1);
    },
    two: function(callback){
        // 执行一些操作后,callback表示本方法执行完成
        callback(null, 2);
    }
},
function(err, results) {
    // 当tasks中的任一方法发生错误,即回调形式为callback('错误信息')时,错误将被传递给err参数,未发生错误err参数为空
    // results中为数组中两个方法的结果对象:{one: 1, two: 2} 
});

3. waterfall(tasks, [callback])

  • 用法

waterfall方法与series方法类似用于依次执行多个方法,一个方法执行完毕后才会进入下一方法

不同与series方法的是:
waterfall之间有数据传递
waterfall的多个方法只能以数组形式传入,不支持object对象。

  • 参数
  • tasks:需要执行多个方法。tasks只能以数组形式传入。每个方法都要一个回调方法callback(err, result1, result2, ...),用于处理错误或进入下一方法。

    当发生错误时(即:err参数存在时),其后的方法会跳过,错误被传入最终回调方法中。无错误时回调参数result1, result2……将做为下一方法的输入参数

  • callback(err, results):可选的最终回调方法。出错时,tasks中抛出的错误将在此方法中捕获,错误被传入err参数。不出错时,tasks中回调结果results为最后一个方法的回调结果。

  • 示例
async.waterfall([
    function(callback) {
        callback(null, 'one', 'two');
    },
    function(arg1, arg2, callback) {
        // arg1 现在是 'one', arg2 现在是 'two' 
        callback(null, 'three');
    },
    function(arg1, callback) {
        // arg1 现在是 'three' 
        callback(null, 'done');
    }
], function (err, result) {
    //执行的任务中方法回调err参数时,将被传递至本方法的err参数
    // 参数result为最后一个方法的回调结果'done'     
});
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 195,980评论 5 462
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 82,422评论 2 373
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 143,130评论 0 325
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 52,553评论 1 267
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 61,408评论 5 358
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 46,326评论 1 273
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 36,720评论 3 386
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 35,373评论 0 254
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 39,678评论 1 294
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 34,722评论 2 312
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 36,486评论 1 326
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 32,335评论 3 313
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 37,738评论 3 299
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,009评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,283评论 1 251
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 41,692评论 2 342
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 40,893评论 2 335

推荐阅读更多精彩内容

  • ** Async ** 机制 是什么? Async 是一个流程控制工具包,提供了直接而强大的异步功能。基于**...
    rangel阅读 1,732评论 2 6
  • 1.nodejs 异步操作小test setTimeout(function(){ console.log('as...
    松爱家的小秦阅读 431评论 0 0
  • Node基本 node的最大特性莫过于基于事件驱动的非阻塞I/O模型。 node通过事件驱动的方式处理请求,无须为...
    AkaTBS阅读 2,146评论 0 11
  • 异步编程对JavaScript语言太重要。Javascript语言的执行环境是“单线程”的,如果没有异步编程,根本...
    呼呼哥阅读 7,285评论 5 22
  • 文件系统模块是一个封装了标准的 POSIX 文件 I/O 操作的集合。通过require('fs')使用这个模块。...
    保川阅读 770评论 0 0