** Async ** 机制 是什么？
Async 是一个流程控制工具包，提供了直接而强大的异步功能。基于**JavaScript **为 Node.js 设计，同时也可以直接在浏览器中使用。
为什么要使用 ** Async ** 机制？
Node.js 使用事件驱动，非阻塞I/O 模型而得以轻量和高效。事件发生后交由指定的程序处理，处理完成后就调用事件回调函数。回调机制使 Node.js 具有了强大的并发处理能力，但也带来了一系列的回调嵌套问题, 解决回调嵌套的方法有很多， ** Async ** 就是为了解决这个问题的
** Async ** 的功能都有什么？
- 流程控制
- 集合处理
- 工具
** 本文章只讨论流程控制部分，其余部分且听下回讲解 **
流程控制的方法都有什么？
流程控制常用的方法有 series、parallel、waterfall、whilst、auto
series parallel waterfall 三种方法的具体用法
1. Async.series(tasks,callback)
-
用法
``series` 方法用于依次执行多个方法，一个方法执行完毕后才会进入下 一方法，方法之间没有数据传递 -
参数
-
tasks：需要执行多个方法。tasks 可以以数组形式传入，也可以以 object 对象形式传入。每个方法都要一个回调方法
-
callback(err, result)：
* 作用：用于处理错误或进入下一方法。当发生错误时（即：err 参数存在时），其后的方法会跳过，错误被传入最终回调方法中
* 出错处理方法：出措时，tasks 中抛出的错误将在此方法中捕获，错误被传入err参数
* 不出错处理方法：不出错时，tasks 中回调结果将被写入 results 参数中，以数据或对象形式提供 -
示例
//以数组形式传入需要执行的多个方法
async.series([
function(callback){
callback(null, 'one');
},
function(callback){
// 执行一些操作后，callback进入可选的最终回调方法
callback(null, 'two');
}
],
// 可选的最终回调
function(err, results){
// 当tasks中的任一方法发生错误，即回调形式为callback('错误信息')时错误将被传递给err参数，未发生错误err参数为空
// results中为数组中两个方法的结果数组：['one', 'two']
});
//以object对象形式传入需要执行的多个方法
async.series({
one: function(callback){
// 执行一些操作后，callback进入下一方法
callback(null, 1);
},
two: function(callback){
// 执行一些操作后，callback进入可选的最终回调方法
callback(null, 2);
}
},
function(err, results) {
// 当tasks中的任一方法发生错误，即回调形式为callback('错误信息')时，错误将被传递给err参数，未发生错误err参数为空
// results中为数组中两个方法的结果对象：{one: 1, two: 2}
});
2. Async.parallel(tasks,callback)
- 用法
parallel方法用于并行执行多个方法，所有传入的方法都是立即执行，方法之间没有数据传递。传递给最终callback的数组中的数据按照tasks中声明的顺序，而不是执行完成的顺序。 - 参数
- tasks：需要执行多个方法。tasks可以以数组形式传入，也可以以object对象形式传入。每个方法都要一个回调方法
-
callback(err,result)：
- 作用:回调方法需要提供一个err参数或是result参数。当发生错误时 (即：err参数存在时)，所有的方法停止执行，未执行完的方法将不会被传递至最终回调方法中
- 出错处理方法：出错时，tasks中抛出的错误将在此方法中捕获，错误被传入err参数
- 不出错：不出错时，tasks中回调结果将被写入results参数中，以数据或对象形式提供。
- 示例
//以数组形式传入需要执行的多个方法
async.parallel([
function(callback){
// 执行一些操作后，callback表示本方法执行完成
callback(null, 'one');
},
function(callback){
// 执行一些操作后，callback表示本方法执行完成
callback(null, 'two');
}
],
// 可选的最终回调
function(err, results){
// 当tasks中的任一方法发生错误，即回调形式为callback('错误信息')时，错误将被传递给err参数，未发生错误err参数为空
// results中为数组中两个方法的结果数组：['one', 'two'] ，即使第二个方法先执行完成，其结果也是在第一个方法结果之后
});
//以object对象形式传入需要执行的多个方法
async.parallel({
one: function(callback){
// 执行一些操作后，callback表示本方法执行完成
callback(null, 1);
},
two: function(callback){
// 执行一些操作后，callback表示本方法执行完成
callback(null, 2);
}
},
function(err, results) {
// 当tasks中的任一方法发生错误，即回调形式为callback('错误信息')时，错误将被传递给err参数，未发生错误err参数为空
// results中为数组中两个方法的结果对象：{one: 1, two: 2}
});
3. Async.waterfall(tasks,callback)
- 用法
waterfall方法与series方法类似用于依次执行多个方法，一个方法执行完毕后才会进入下一方法，不同与series方法的是，waterfall之间有数据传递。waterfall的多个方法只能以数组形式传入，不支持object对象 - 参数
- tasks：需要执行多个方法。tasks只能以数组形式传入。每个方法都要一个回调方法callback(err, result1, result2, ...)，用于处理错误或进入下一方法。当发生错误时（即：err参数存在时），其后的方法会跳过，错误被传入最终回调方法中。无错误时回调参数result1, result2……将做为下一方法的输入参数
- callback(err,result)：
- 出错处理方法：出错时，tasks中抛出的错误将在此方法中捕获，错误被传入err参数
- 不出错：不出错时，tasks中回调结果results为最后一个方法的回调结果
- 示例：
async.waterfall([
function(callback) {
callback(null, 'one', 'two');
},
function(arg1, arg2, callback) {
// arg1 现在是 'one'， arg2 现在是 'two'
callback(null, 'three');
},
function(arg1, callback) {
// arg1 现在是 'three'
callback(null, 'done');
}
], function (err, result) {
//执行的任务中方法回调err参数时，将被传递至本方法的err参数
// 参数result为最后一个方法的回调结果'done'
});
总结
series：多个任务依次执行
parallel：多个任务并发执行
waterfall：多个任务依次执行，上一任务的输出可做为下一任务的输入参数
网友评论