深入学习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参数限制了同时并发执行的个数,不再是无限并发

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") 
 },3000); 
} 
 
var task3 =function(callback){ 
 
 console.log("task3"); 
 setTimeout(function(){ 
 callback(null,"task3") 
 },4000); 
} 
console.time("parallelLimit方法"); 
async.parallelLimit([task1,task2,task3], 2, function(err,result){ 
 
 console.log("parallelLimit"); 
 
 if (err) { 
 console.log(err); 
 } 
 
 console.log(result); 
 console.timeEnd("parallelLimit方法"); 
}) 

运行结果:

三个函数分别是延迟5000ms,3000ms,4000ms结果执行时间为什么是7000ms呢

因为首先执行函数1和2,

3秒后函数2执行完毕,这个时候函数3开始执行,

5秒后函数1执行完毕,函数3还有2秒,

7秒后函数3执行完毕.

5.auto(tasks,[callback])

多个函数有数据交互,有的并行,有的依次执行

console.time("auto方法"); 
async.auto({ 
 task1: function(callback){ 
 console.log("tsak1"); 
 setTimeout(function(){ 
 callback(null, 'task11', 'task12'); 
 },2000); 
 }, 
 task2: function(callback){ 
 console.log('task2'); 
 setTimeout(function(){  
 callback(null, 'task2'); 
 },3000); 
 }, 
 task3: ['task1', 'task2', function(callback, results){ 
 console.log('task3'); 
 console.log('task1和task2运行结果: ',results); 
 setTimeout(function(){  
 callback(null, 'task3'); 
 },1000); 
 }], 
 task4: ['task3', function(callback, results){ 
 console.log('task4'); 
 console.log('task1,task2,task3运行结果: ',results); 
 setTimeout(function(){ 
 callback(null, {'task41':results.task3, 'task42':'task42'}); 
 },1000); 
 }] 
}, function(err, results) { 
 console.log('err :', err); 
 console.log('最终results : ', results); 
 console.timeEnd("auto方法"); 
}); 

运行结果:

5秒运行完毕,

函数1和2并行,3秒执行完毕,

函数1和2执行完毕后,函数3,4依次执行共计5秒.

6.whilst(test,fn,[callback])

相当于while循环,fn函数里不管是同步还是异步都会执行完上一次循环才会执行下一次循环,对异步循环很有帮助,
test是条件,为true时执行fn里的方法

var datalist = [{number:10},{number:20},{number:30},{number:40},{number:50}]; 
var count = 0; 
 
var test = function () { 
 return count<datalist.length; 
}; 
 
var fn = function(callback){ 
 console.log(datalist[count].number); 
 setTimeout(function () { 
 count++; 
 callback(); 
 },1000) 
}; 
 
async.whilst(test,fn,function(err){ 
 if(err){ 
 console.log(err); 
 } 
 console.log('whilst结束'); 
}); 

运行结果:

7.doWhilst

和whilst类似,和do-while一个意思,首先执行一次fn,再判断,和whilst相比它把fn和test位置交换了而已.

until和whilst相反,当test判断为false的时候执行fn里的方法,为true时跳出,

doUntil与doWhilst相反.

8.forever(fn,errback)

forever就是无限循环了.只有当中途出现错误的时候才会停止

var count = 0; 
async.forever(function(callback){ 
 console.log(count); 
 count++; 
 
 if (count>10) { 
 callback("errmessage"); 
 return; 
 } 
 
 setTimeout(function () { 
 callback(); 
 },1000) 
}, 
function(err){ 
 console.log(err); 
}); 

运行结果:

9.compose(fn1,fn2,fn3...)

这个方法会创建一个异步的集合函数,执行的顺序是倒序.前一个fn的输出是后一个fn的输入.有数据交互

var task1 =function(m,callback){ 
 
 console.log("task1"); 
 setTimeout(function(){ 
 callback(null,m*2) 
 },1000); 
 
} 
 
var task2 =function(m,callback){ 
 
 console.log("task2"); 
 
 setTimeout(function(){ 
 callback(null,m+3) 
 },1000); 
} 
 
var task3 =function(m,callback){ 
 
 console.log("task3"); 
 setTimeout(function(){ 
 callback(null,m*5) 
 },1000); 
} 
console.time("compose方法"); 
 
var com = async.compose(task3,task2,task1); 
 
com(2,function(err,result){ 
 if (err) { 
 console.log(err); 
 } 
 console.log(result); 
 console.timeEnd("compose方法"); 
}) 

运行结果:

相当于 var m=2; (m*2+3)*5 =35;

在我的项目开发中waterfall用的最多.

更多方法详情 : https://www.npmjs.com/package/async

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# nodejs  # async模块  # nodejs的async  # nodejs URL模块操作URL相关方法介绍  # Nodejs使用mysql模块之获得更新和删除影响的行数的方法  # nodejs使用http模块发送get与post请求的方法示例  # nodejs基于WS模块实现WebSocket聊天功能的方法  # Nodejs调用Dll模块的方法  # nodejs 日志模块winston的使用方法  # nodejs 使用 js 模块的方法实例详解  # NodeJs 文件系统操作模块fs使用方法详解  # nodejs中方法和模块用法示例  # 多个  # 中途  # 回调  # 才会  # 出现错误  # 一个函数  # 最多  # 很有  # 执行时间  # 换了  # 相互之间  # 这个时候  # 这两天  # 错误信息  # 而生  # 创建一个  # 大家多多  # 发生错误  # 装好  # 则将 

相关文章： 武汉外贸网站制作公司,现在武汉外贸前景怎么样啊？  如何通过wdcp面板快速创建网站？  制作网站软件推荐手机版,如何制作属于自己的手机网站app应用？  如何在IIS7中新建站点？详细步骤解析  整蛊网站制作软件,手机不停的收到各种网站的验证码短信,是手机病毒还是人为恶搞?有这种手机病毒吗？  可靠的网站设计制作软件,做网站设计需要什么样的电脑配置？  网站网页制作专业公司,怎样制作自己的网页？  如何在橙子建站上传落地页？操作指南详解  如何在Golang中指定模块版本_使用go.mod控制版本号  建站主机如何选？高性价比方案全解析  建站主机选购指南与交易推荐：核心配置解析  北京网站制作公司哪家好一点,北京租房网站有哪些？  建站之星安装需要哪些步骤及注意事项？  如何通过NAT技术实现内网高效建站？  文字头像制作网站推荐软件,醒图能自动配文字吗？  自助网站制作软件,个人如何自助建网站？  简历在线制作网站免费,免费下载个人简历的网站是哪些？  专业网站建设制作报价,网页设计制作要考什么证？  定制建站流程步骤详解：一站式方案设计与开发指南  如何自定义建站之星模板颜色并下载新样式？  ,巨量百应是干嘛的？  阿里云网站搭建费用解析：服务器价格与建站成本优化指南  电视网站制作tvbox接口,云海电视怎样自定义添加电视源？  Dapper的Execute方法的返回值是什么意思 Dapper Execute返回值详解  整人网站在线制作软件,整蛊网站退不出去必须要打我是白痴才能出去？  网站制作中优化长尾关键字挖掘的技巧,建一个视频网站需要多少钱？  建站主机类型有哪些？如何正确选型  如何在香港免费服务器上快速搭建网站？  Thinkphp 中 distinct 的用法解析  如何高效利用亚马逊云主机搭建企业网站？  如何高效配置IIS服务器搭建网站？  香港服务器网站卡顿？如何解决网络延迟与负载问题？  教学网站制作软件,学习*后期制作的网站有哪些？  如何通过宝塔面板实现本地网站访问？  如何用PHP工具快速搭建高效网站？  建站之星导航菜单设置与功能模块配置全攻略  建站之星如何实现网站加密操作？  香港服务器WordPress建站指南：SEO优化与高效部署策略  已有域名能否直接搭建网站？  实惠建站价格推荐：2025年高性价比自助建站套餐解析  建站之星安装后如何自定义网站颜色与字体？  浅析上传头像示例及其注意事项  中山网站推广排名,中山信息港登录入口？  学生网站制作软件,一个12岁的学生写小说，应该去什么样的网站？  如何选择靠谱的建站公司加盟品牌？  如何选择美橙互联多站合一建站方案？  山东云建站价格为何差异显著？  广州网站制作公司哪家好一点,广州欧莱雅百库网络科技有限公司官网？  如何用5美元大硬盘VPS安全高效搭建个人网站？  建设网站制作价格,怎样建立自己的公司网站？