浅析node Async异步处理模块用例分析及常用方法介绍
最近在研究nodejs，令我感受比较深的是……熟悉js代码的地球人都知道，js的加载顺序很重要！很重要！！那么问题来了，在编写node的时候，会在后台去请求很多接口（我们公司是与java后台交接数据的），接口就会有个回调，这么多回调怎么办呢……每个回调回来的加载顺序怎么去处理是个问题……总不可能去嵌套……嵌套……这样吧，那会显的多麻烦！！这么大的一个问题怎么没有处理方法呢，那是不可能的……对吧！
Async异步处理模块！
以下是小sam的理解：
安装很简单，就跟普通的安装模块一样就行了
这样就安装成功了！接下来就是引用了，在代码里引用模块：
varasync=require('async');
这样引用也就ok了！在代码后面就可以轻松的用async这个对像模块了！
查了下官方文档，这个模块的方法实在是太多了！看的眼花……
下面我们来谈谈小编觉得比较常用到的几个方法就好了
series
1.series(tasks,[callback])顺序执行数组、集合内的函数，当前面一个函数执行完成就会立即执行下一个函数，如果函数触发了错误，可以在callback函数中验证，否则会一直执行完成tasks
话多没用，代码才是亲爹
用例：
//tasks传的是一个数组函数
async.series([
function(callback){
//dosomestuff...
callback(null,'one');
},
function(callback){
//dosomemorestuff...
callback(null,'two');
}],
//optionalcallback
//我觉得这里很重要err是上面两个函数的错误信息，而results这个参数是一个数组对象，它们的值是上面数组函数每个callback里面的参数。
function(err,results){
//resultsisnowequalto['one','two']
});
//anexampleusinganobjectinsteadofan
//下面的代码其实跟上面的差不多，只是stasks传的是对象而不是数组
async.series({
one:function(callback){
setTimeout(function(){
callback(null,1);
},
200);
},
two:function(callback){
setTimeout(function(){
callback(null,2);
},
100);
}
},
function(err,results){
//resultsisnowequalto:{one:1,two:2}
});
parallel
2.parallel(tasks,[callback])并行执行数组、集合内的方法，不用等到前一个函数执行完再执行下一个函数，如果函数触发了错误，可以在callback函数中验证
async.parallel(
[
function(callback){
setTimeout(function(){
callback(null,'one');
},
200);
},
function(callback){
setTimeout(function(){
callback(null,'two');
},
100);
}
],
//optionalcallback
function(err,results){
//theresultsarraywillequal['one','two']eventhoug
//thesecondfunctionhadashorter
timeout
}
);
parallelLimit
3.parallelLimit(tasks,limit,[callback])和2用法一样，只是多了一个任务数量限制，最多允许多少个任务在并行执行
whilst
4.whilst(test,fn,callback)等同于while的用法，第一个参数为验证条件，第二个参数为执行函数，第三个参数为验证失败后回调函数，一般在做延迟动画用的比较多
varcount=0;
async.whilst(
function(){returncount<5;},
//验证成功继续，失败进回调
function(callback){
count++;
setTimeout(callback,1000);
},
function(err){
//5secondshavepassed
}
);
waterfall
5.waterfall(tasks,[callback])tasks依次运行,前一个函数的回调会作为后一个函数的参数，如果有任何任务通过一个错误的回调，下一个函数不执行
async.waterfall([
function(callback){
callback(null,'one','two');
},
function(arg1,arg2,callback){
//arg1nowequals'one'andarg2nowequals'two'
callback(null,'three');
},
function(arg1,callback){
//arg1nowequals'three'
callback(null,'done');
}
],function(err,result){
//resultnowequals'done'
});
compose
6.compose(fn1,fn2...)按顺序加入到队列中，按顺序执行，将上一个函数的结果作为下一个函数的值
functionadd1(n,callback){
setTimeout(function(){
callback(null,n+1);
},10);
}
functionmul3(n,callback){
setTimeout(function(){
callback(null,n*3);
},10);
}
varadd1mul3=async.compose(mul3,add1);
add1mul3(4,function(err,result){
//resultnowequals15
});
总结
以上所述是小编给大家介绍的浅析nodeAsync异步处理模块用例分析及常用方法介绍，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持！