从零学习node.js之详解异步控制工具async(八)
发布时间 - 2026-01-10 23:18:07 点击率:次前言

大家在编写异步程序时,最头痛的就是不知道结果什么时候返回给我们,然后执行后面的操作,很多时候只能把后面的操作放到返回成功的函数里,或者使用计数器等方法。
比较典型的两个就是:后面的操作需要依赖上一个异步操作的结果;多个异步操作并行执行,都执行完成后再执行接下来的操作。
这两个操作中,第一个异步的程序我们可能会写成这样:
db.select(SQL1, function(res1){
db.delete(SQL2, function(res2){
db.insert(SQL3, function(res3){
// ...
})
})
});
将后面的操作写到执行成功后的回调函数里。第2个并行的异步操作,可以使用计数器的方法,每个异步调用成功时,计数器加1,当所有的异步都调用成功后,再接着执行:
var count = 0;
var success = function(){
count++;
if(count>=3){
console.log('执行完毕...');
}
}
var select = function(){
db.select(sql, function(res){
success();
})
}
var select2 = function(){
db.select(sql, function(res){
success();
})
}
var select3 = function(){
db.select(sql, function(res){
success();
})
}
select();
select2();
select3();
这些编写方式非常麻烦,而且代码逻辑比较混乱,调试起来也很不方便。那么就要用到异步控制的利器async了。
介绍
async的作用是进行流程的控制,而且提供了非常多的方法可供调用。
这些方法可以分为三大类:
- 集合类(Collections)
- 流程控制类(Control Flow)
- 工具类(Utils)
下面我们从这三个分类里分别挑出几个方法进行讲解。
二、函数介绍
async中提供了非常多的方法可供使用,我们仅仅是讲解其中几个比较有代表性的,其他的可以访问官方文档:http://caolan.github.io/async/docs.html。
2.1 集合类
集合类中的方法主要有some, ‘map', ‘each', ‘every'等,这些方法是对数组或组合进行某个相同的操作后,统一执行回调函数。
我们以map为例,map对集合中的每一个元素,执行某个相同的异步操作,得到结果。所有的结果将汇总到最终的callback里。
使用方法,map接收三个参数,分别是:
| 参数名称 | 类型 | 说明 |
| coll | iteratee | callback |
| Array | Iterable | Object | function | function |
| 需要处理数组,集合或其他可迭代的类型 | 迭代方法,用来对集合中的每一项进行处理。该方法接收两个参数(item, callback);item为集合中的每一项, callback为回调函数。callback需要带有err(有时可能为null)和处理后的数据,callback(err, data) | 最终回调函数,当集合处理完毕后调用此函数,传递两个参数err和result,result为之前处理后的所有的结果的集合 |
注意:中间处理函数iteratee对coll中的每一项都是并发处理的,因此并不能保证iteratee按照顺序完成。不过,如果coll是个数组,最后的结果集results会按照coll中的顺序排列;如果coll是个集合(Object)类型,results会是数组类型,结果将大致按照coll的键的顺序排列(但是不同在不同的JavaScript引擎中会有可能发生变化)。
我们来举个例子,使用map获取几个文件中的内容:
var files = ['./file/cnode_1.txt', './file/cnode_2.txt', './file/cnode_3.txt'];
// 读取文件内容
// 第1个参数 文件名称列表的数组
// 第2个参数 传入数组中的每一项和回调函数
// 第3个参数 results为所有结果的集合
async.map(files, function(file, cb){
fs.readFile(file, 'utf-8', function(err, data){
cb(err, data);
})
}, function(err, results){
console.log( results );
})
而且,如果中间的处理函数比较大,不想写在map中,也可以单独写成一个函数,然后传递进去,不过参数传递还是要符合规则的:
var files = ['./file/cnode_1.txt', './file/cnode_2.txt', './file/cnode_3.txt'];
var read = function(file, cb){
fs.readFile(file, 'utf-8', function(err, data){
cb(err, data);
})
}
async.map(files, read, function(err, result){
console.log( result );
})
这里还有一个mapLimit,可以传递一个参数limit,用来限制并发的数量:mapLimit(coll, limit, iteratee, callbackopt) :
// 并发数量为2
async.mapLimit(files, 2, read, function(err, result){
console.log( result );
})
同时,集合类中还有其他的方法,我们也稍微了解下:
- each : 与map类似,但是最后的回调函数里没有results,each只循环不负责处理结果
- every : 中间处理函数iteratee的参数(err, boolean)需要传递一个boolean值,若所有选项的结果都为true,则results为true
- some : 与every类似,只是只要其中一个选项的结果为true,则results为true
- filter : 对coll进行筛选,筛选出结果为true的结果
- reject : 与filter正好相反,筛选出结果为false的结果
- concat : 将每个异步操作的结果合并为一个数组
2.2 流程控制类
上面的集合类是对一个集合进行相同的处理,集合中的每一项都处理完后,再对结果进行回调处理。而多个回调方法执行时,则需要对这几个回调方法进行控制了。
多个回调方法执行时,通常有这么几个流程:
- 串行且无关联,即执行完一个后再依次执行下一个,且相互之间无数据交互,都执行完后,再执行最后的回调函数。可以使用
async.series - 串行且有关联,即执行完一个后再依次执行下一个,且上一个回调函数的结果会作为下一个回调函数的参数。可以使用async.waterfall
- 并行,这几个回调函数同时并发执行,都执行完成后,再执行最后的回调函数。可以使用
async.parallel
当然还有其他更复杂的流程,这里也只聊上面的三种情况。
async.series,async.waterfall和async.parallel的语法都是一样的:
async.Method(coll, function(err, results){
})
其中coll既可以是数组,也可以是json格式的,而且results的类型与coll对应。
串行且无关联async.series:
// 串行且无关联,数组格式
async.series([
function(cb){
getAllList(function(result){
cb(null, result);
});
},
function(cb){
getAllUser(function(result){
cb(null, result);
});
}
], function(err, result){
console.log(result);
})
同时串行的异步可以是json格式的:
// 串行且无关联,json个数
async.series({
one: function(cb){
getAllList(function(result){
cb(null, result);
});
},
two: function(cb){
getAllUser(function(result){
cb(null, result);
});
}
}, function(err, result){
console.log(result);
})
串行且有关联async.waterfall:
// 串行且上一个结果作为下一个的参数
async.waterfall([
function(cb){
getListById(1, function(result){
cb(null, result);
});
},
function(params, cb){
console.log(params);
getAllUser(function(result){
cb(null, result);
});
}
], function(err, result){
console.log(result);
})
并行async.parallel:
// 并行,getAllList与getAllUser同时执行
async.parallel([
function(cb){
getAllList(function(result){
cb(null, result);
});
},
function(cb){
getAllUser(function(result){
cb(null, result);
});
}
], function(err, result){
console.log(result);
})
关于并行的异步操作,这里还有一个async.parallelLimit,限制并发的数量:
// 并发数量为2
async.parallelLimit([
iteratee1, iteratee2, iteratee3, ...
], 2, function(err, results){
})
2.3 工具类
async中也提供了不少的工具方法可供使用,比如async.log可以输出回调方法中的值,第1个参数为函数,后面的参数为传递给函数的参数:
var hello = function(name, callback) {
setTimeout(function() {
callback(null, 'hello ' + name);
}, 1000);
};
// 将'world'传递给hello方法
async.log(hello, 'world'); // 'hello world'
这里面还有apply, dir, timeout等方法。
总结
使用async控制异步流程非常的方便,而且也可以在前端使用,比如可以操作多个ajax请求等。好了,以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对的支持。
# nodejs
# async
# async使用方法
# 异步流程控制
# 详解Node.js中的Async和Await函数
# Node.js 中使用 async 函数的方法
# 浅析node Async异步处理模块用例分析及常用方法介绍
# nodejs async异步常用函数总结(推荐)
# 在 Node.js 中使用 async 函数的方法
# NodeJs通过async/await处理异步的方法
# 深入学习nodejs中的async模块的使用方法
# async/await与promise(nodejs中的异步操作问题)
# 浅谈node.js中async异步编程
# node 使用 async 控制并发的方法
# 回调
# 几个
# 多个
# 可以使用
# 每一项
# 可供
# 是个
# 其他的
# 还有一个
# 这几个
# 完后
# 量为
# 类中
# 都是
# 顺序排列
# 迭代
# 完成后
# 好了
# 第一个
# 有可能
相关栏目:
【
网站优化151355 】
【
网络推广146373 】
【
网络技术251813 】
【
AI营销90571 】
相关推荐:
微信小程序 五星评分(包括半颗星评分)实例代码
打造顶配客厅影院,这份100寸电视推荐名单请查收
laravel怎么通过契约(Contracts)编程_laravel契约(Contracts)编程方法
香港服务器租用费用高吗?如何避免常见误区?
Win11怎么修改DNS服务器 Win11设置DNS加速网络【指南】
C语言设计一个闪闪的圣诞树
北京网站制作的公司有哪些,北京白云观官方网站?
Python高阶函数应用_函数作为参数说明【指导】
Python自动化办公教程_ExcelWordPDF批量处理案例
Laravel怎么实现前端Toast弹窗提示_Laravel Session闪存数据Flash传递给前端【方法】
java ZXing生成二维码及条码实例分享
javascript和jQuery中的AJAX技术详解【包含AJAX各种跨域技术】
Android滚轮选择时间控件使用详解
DeepSeek是免费使用的吗 DeepSeek收费模式与Pro版本功能详解
如何用美橙互联一键搭建多站合一网站?
三星、SK海力士获美批准:可向中国出口芯片制造设备
Laravel怎么实现一对多关联查询_Laravel Eloquent模型关系定义与预加载【实战】
在线教育网站制作平台,山西立德教育官网?
大连网站制作费用,大连新青年网站,五年四班里的视频怎样下载啊?
如何在服务器上配置二级域名建站?
浅述节点的创建及常见功能的实现
Windows Hello人脸识别突然无法使用
成都品牌网站制作公司,成都营业执照年报网上怎么办理?
Bootstrap整体框架之JavaScript插件架构
如何在沈阳梯子盘古建站优化SEO排名与功能模块?
香港服务器网站推广:SEO优化与外贸独立站搭建策略
Laravel Telescope怎么调试_使用Laravel Telescope进行应用监控与调试
HTML 中动态设置元素 name 属性的正确语法详解
iOS UIView常见属性方法小结
详解一款开源免费的.NET文档操作组件DocX(.NET组件介绍之一)
如何在IIS服务器上快速部署高效网站?
Laravel Eloquent模型如何创建_Laravel ORM基础之Model创建与使用教程
Win11关机界面怎么改_Win11自定义关机画面设置【工具】
JavaScript数据类型有哪些_如何准确判断一个变量的类型
详解jQuery中基本的动画方法
Win11怎么更改系统语言为中文_Windows11安装语言包并设为显示语言
如何续费美橙建站之星域名及服务?
如何破解联通资金短缺导致的基站建设难题?
canvas 画布在主流浏览器中的尺寸限制详细介绍
如何在景安服务器上快速搭建个人网站?
html5怎么画眼睛_HT5用Canvas或SVG画眼球瞳孔加JS控制动态【绘制】
Laravel如何创建自定义中间件?(Middleware代码示例)
Laravel怎么多语言本地化设置_Laravel语言包翻译与Locale动态切换【手册】
Java遍历集合的三种方式
作用域操作符会触发自动加载吗_php类自动加载机制与::调用【教程】
Bootstrap整体框架之CSS12栅格系统
英语简历制作免费网站推荐,如何将简历翻译成英文?
Angular 表单中正确绑定输入值以确保提交与验证正常工作
瓜子二手车官方网站在线入口 瓜子二手车网页版官网通道入口
制作网站软件推荐手机版,如何制作属于自己的手机网站app应用?

