前言
大家在编写异步程序时,最头痛的就是不知道结果什么时候返回给我们,然后执行后面的操作,很多时候只能把后面的操作放到返回成功的函数里,或者使用计数器等方法。
比较典型的两个就是:后面的操作需要依赖上一个异步操作的结果;多个异步操作并行执行,都执行完成后再执行接下来的操作。
这两个操作中,第一个异步的程序我们可能会写成这样:
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的作用是进行流程的控制,而且提供了非常多的方法可供调用。
这些方法可以分为三大类:
下面我们从这三个分类里分别挑出几个方法进行讲解。
二、函数介绍
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 ); })
同时,集合类中还有其他的方法,我们也稍微了解下:
2.2 流程控制类
上面的集合类是对一个集合进行相同的处理,集合中的每一项都处理完后,再对结果进行回调处理。而多个回调方法执行时,则需要对这几个回调方法进行控制了。
多个回调方法执行时,通常有这么几个流程:
当然还有其他更复杂的流程,这里也只聊上面的三种情况。
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请求等。好了,以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对小牛知识库的支持。
本文向大家介绍从零学习node.js之express入门(六),包括了从零学习node.js之express入门(六)的使用技巧和注意事项,需要的朋友参考一下 一、 介绍 什么是express,为什么要使用express?根据官方网站的说法,express是一个基于 Node.js 平台的极简、灵活的web应用开发框架,它提供一系列强大的特性、丰富的API接口,对web应用的接口进行了二次的封装,
本文向大家介绍从零学习node.js之模块规范(一),包括了从零学习node.js之模块规范(一)的使用技巧和注意事项,需要的朋友参考一下 什么是Node.js? 很多初学者并没有真正地理解Node.js到底是什么。nodejs.org网站中的描述也没有多大帮助。 首先要清楚Node不是一个Web服务器,这十分重要。它本身并不能做任何事情。它无法像Apache那样工作。如果你希望它成为一个HTTP
本文向大家介绍详解koa2学习中使用 async 、await、promise解决异步的问题,包括了详解koa2学习中使用 async 、await、promise解决异步的问题的使用技巧和注意事项,需要的朋友参考一下 关键词:async 、await、promise 这三个东西 可以优雅的解决异步问题。在学习koa2的时候遇到了获取数据后再进行模板渲染的异步问题。在查找各种资料后成功的解决了该问
本文向大家介绍Symfony2学习笔记之控制器用法详解,包括了Symfony2学习笔记之控制器用法详解的使用技巧和注意事项,需要的朋友参考一下 本文实例讲述了Symfony2控制器用法。分享给大家供大家参考,具体如下: 一个controller是你创建的一个PHP函数,它接收HTTP请求(request)并创建和返回一个HTTP回复(Response)。回复对象(Response)可以是一个HTM
本文向大家介绍Node.js异步I/O学习笔记,包括了Node.js异步I/O学习笔记的使用技巧和注意事项,需要的朋友参考一下 “异步”这个名词的大规模流行是在Web 2.0浪潮中,它伴随着Javascript和AJAX席卷了Web。但在绝大多数高级编程语言中,异步并不多见。PHP最能体现这个特点:它不仅屏蔽了异步,甚至连多线程也不提供,PHP都是以同步阻塞的方式来执行。这样的优点利于程序猿顺序编
本文向大家介绍Javascript异步流程控制之串行执行详解,包括了Javascript异步流程控制之串行执行详解的使用技巧和注意事项,需要的朋友参考一下 这篇文章主要讲一下如何串行执行一组异步任务,例如有下面几个任务,在这里我们用setTimeout模拟一个异步任务: 直接运行 是达不到顺序执行A,B,C 的三个任务的效果的。 首先我们看一下最传统的做法,通过回调的方式在一个任务执行完成之后调用