深入学习nodejs中的async模块的使用方法

最近在学习nodejs，这两天学习了async模块这个地方知识点挺多的，所以，今天添加一点小笔记。

async模块是为了解决嵌套金字塔,和异步流程控制而生.常用的方法介绍

npm 安装好async模块,然后引入就可以使用 var async = require('async');

1. series(tasks,[callback])

多个函数从上到下依次执行,相互之间没有数据交互

var task1 =function(callback){ console.log("task1"); callback(null,"task1") } var task2 =function(callback){ console.log("task2"); callback(null,"task2") } var task3 =function(callback){ console.log("task3"); callback(null,"task3") } async.series([task1,task2,task3],function(err,result){ console.log("series"); if (err) { console.log(err); } console.log(result); })

运行结果:

如果中途发生错误,则将错误传递到回调函数,并停止执行后面的函数

var task1 =function(callback){ console.log("task1"); callback(null,"task1") } var task2 =function(callback){ console.log("task2"); callback("err","task2") } var task3 =function(callback){ console.log("task3"); callback(null,"task3") } async.series([task1,task2,task3],function(err,result){ console.log("series"); if (err) { console.log(err); } console.log(result); })

运行结果:

2.parallel(tasks,[callback])

多个函数并行执行,不会等待其他函数

var task1 =function(callback){ console.log("task1"); setTimeout(function(){ callback(null,"task1") },5000); } var task2 =function(callback){ console.log("task2"); setTimeout(function(){ callback(null,"task2") },1000); } var task3 =function(callback){ console.log("task3"); setTimeout(function(){ callback(null,"task3") },3000); } console.time("parallel方法"); async.parallel([task1,task2,task3],function(err,result){ console.log("parallel"); if (err) { console.log(err); } console.log(result); console.timeEnd("parallel方法"); })

运行结果:

3个函数分别延迟5000ms,1000ms,3000ms 结果5000ms就执行完毕.

如果中途出错,则立即将err和值传到最终的回调函数,其他未执行完毕的函数将不再执行,但是要占一个位置

var task1 =function(callback){ console.log("task1"); setTimeout(function(){ callback(null,"task1") },5000); } var task2 =function(callback){ console.log("task2"); setTimeout(function(){ callback("errmessage","task2") },3000); } var task3 =function(callback){ console.log("task3"); setTimeout(function(){ callback(null,"task3") },1000); } console.time("parallel方法"); async.parallel([task1,task2,task3],function(err,result){ console.log("parallel"); if (err) { console.log(err); } console.log(result); console.timeEnd("parallel方法"); })

运行结果:

3.waterfall(tasks,[callback]) :瀑布流

依次执行,前一个函数的输出为后一个函数的输入

var task1 =function(callback){ console.log("task1"); callback(null,"11") } var task2 =function(q,callback){ console.log("task2"); console.log("task1函数传入的值: "+q); callback(null,"22") } var task3 =function(q,callback){ console.log("task3"); console.log("task2函数传入的值: "+q); callback(null,"33") } console.time("waterfall方法"); async.waterfall([task1,task2,task3],function(err,result){ console.log("waterfall"); if (err) { console.log(err); } console.log("result : "+result); console.timeEnd("waterfall方法"); })

执行结果:

 

如果中途出现错误,后面的函数将不在执行,之前执行的结果和错误信息将直接传到最终的回调函数

var task1 =function(callback){ console.log("task1"); callback(null,"11") } var task2 =function(q,callback){ console.log("task2"); console.log("task1函数传入的值: "+q); callback("errmessage","22") } var task3 =function(q,callback){ console.log("task3"); console.log("task2函数传入的值: "+q); callback(null,"33") } console.time("waterfall方法"); async.waterfall([task1,task2,task3],function(err,result){ console.log("waterfall"); if (err) { console.log(err); } console.log("result : "+result); console.timeEnd("waterfall方法"); })

运行结果:

4.parallelLimit(tasks,limit,[callback])

和parallel类似,只是limit参数限制了同时并发执行的个数,不再是无限并发