8. series/parallel/parallelLimit
async.eachOfSeries(arr, iterator, callback)是对arr中的每一项，调用iterator函数，最终调用callback。也就是说，所有的异步任务都是同一种类型，只是传入的参数不同。例如对于一个目录下的所有文件，统计每个文件的size。
因此async.eachOfSeries无法处理多个不同类型的异步任务的情况，例如多个异步任务，一个是请求远程数据，一个是判断文件是否存在，还有一些其它类型的任务。这种情况下需要一个新的函数series。
series是基于async.eachOfSeries来实现，基本逻辑如下：
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 |
function series(tasks, callback) { callback = callback || function() {}; var results = Array.isArray(tasks) ? [] : {}; async.eachOfSeries(tasks, function(task, key, callback) { task(function(err, data) { // [2] results[key] = data; // [3] callback(err); // [4] }); }, function(err) { // [5] callback(err, results); // [6] }); } // example series([function(callback) { fs.access('index.js', function(err) { callback(null, err ? false : true); // [1] }); }, function(callback) { fs.readFile('package.json', function(err, data) { callback(err, data); // [1] }); }], function(err, results) { if (err) { throw err; } console.log(results); }); |
|
1 |
<span style="font-weight: normal">这里有很多callback，比较迷惑人。现在将它们分类如下：</span> |
- 每个task的回调，记作
taskCallback async.eachOfSeries第二个参数中的回调，记作iteratorCallbackasync.eachOfSeries的第三个参数也是一个回调（相关代码参看eachOfSeries的实现），记作eachOfSeriesCallbackseries的第二个参数，记作seriesCallback
现在来分析series的执行流程：
- 依次执行每个task，在这个过程中，会由用户调用
taskCallback（[1]） taskCallback其实是在series的实现中定义（[2]）- 在执行
taskCallback的时候，会先将task的结果储存在结果集合中（[3]），然后调用iteratorCallback（[4]） iteratorCallback的作用是判断任务是否执行完毕，如果没有执行完毕，则继续执行下一个任务；如果任务执行完毕，则执行eachOfSeriesCallback（该部分的逻辑在async.eachOfSeries中实现）- 当所有task执行完毕后，或者任务执行过程中出错时，会执行
eachOfSeriesCallback（[5]） - 在
eachOfSeriesCallback中，执行seriesCallback（[6]），至此，series的执行过程结束
parallel/parallelLimit与series的实现类似，只不过是将async.eachOfSeries换成了async.eachOf/async.eachOfLimit来实现。
9. waterfall
series模型的多个任务之间是没有依赖关系的。但是如果一个任务的执行依赖于上一个任务的结果，series就无法处理了，此时需要使用waterfall，即每个任务的执行结果会传递给下一个任务。
一个简单的实现思路是：将每一步任务的结果储存在一个变量中，然后将该变量传入下一个任务作为参数。基本逻辑如下：
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 |
function waterfall(tasks, callback) { callback = callback || function() {}; tasks = tasks || []; // 由于传入下一个任务的参数可能不止一个，因此使用一个数组来保存中间值 var result = []; var slice = result.slice; async.eachOfSeries(tasks, function(task, key, callback) { result.push(function(err) { result = slice.call(arguments, 1); ۮ录下的所有文件，统计每个文件的size。
因此
现在来分析
9. waterfallseries模型的多个任务之间是没有依赖关系的。但是如果一个任务的执行依赖于上一个任务的结果， 一个简单的实现思路是：将每一步任务的结果储存在一个变量中，然后将该变量传入下一个任务作为参数。基本逻辑如下：
|
