async.js 学习教程（二）

浏览数：18 / 时间：2015年06月09日

Collections

详情请参考：http://freewind.me/blog/20120518/932.html

collections模块主要实现对集合的遍历，排序，过滤，查询等功能

forEach：对集合中每个元素进行异步操作
map：对集合中的每个元素通过异步操作得到另一个值，得到新的集合
filter：对集合中元素使用异步操作进行筛选，得到符合条件的集合
reject：与filter相似，只是判断条件时正好相反，得到剩下的元素的集合
reduce：使用一个初始值同集合中每一个元素进行异步操作，最后得到一个唯一的结果
detect：得到集合中满足条件的第一个数据
sortBy：对集合中的数据进行异步操作，再根据值从小到大排序
some/any：集合中是否有至少一个元素满足条件
every/all：集合中是否每个元素都满足条件
concat：对集合中的元素进行异步操作，将结果集合并成一个数组

1.each(arr, iterator, callback)　　第一个参数为数组（array），第二个参数为iterator(item, callback)，其中item为数组内元素，callback为回调，第三个参数为回调函数，用法为迭代数组内每一个元素，执行一个方法，完成时可以调用回调，当迭代器返回一个错误回调，可执行处理函数

如果想对同一个集合中的所有元素都执行同一个异步操作，可以利用forEach函数。注意该函数将重点放在“执行过程”上，忽略运行后产生的数据。如果需要结果，可使用map函数。

根据执行的方式不同，forEach提供了三个版本：

集合中所有元素并行执行
一个一个顺序执行
分批执行，同一批内并行，批与批之间按顺序

 1 // assuming openFiles is an array of file names 
 2 
 3 async.each(openFiles, function( file, callback) {
 4 
 5   // Perform operation on file here.
 6   console.log(‘Processing file ‘ + file);
 7 
 8   if( file.length > 32 ) {
 9     console.log(‘This file name is too long‘);
10     callback(‘File name too long‘);
11   } else {
12     // Do work to process file here
13     console.log(‘File processed‘);
14     callback();
15   }
16 }, function(err){
17     // if any of the file processing produced an error, err would equal that error
18     if( err ) {
19       // One of the iterations produced an error.
20       // All processing will now stop.
21       console.log(‘A file failed to process‘);
22     } else {
23       console.log(‘All files have been processed successfully‘);
24     }
25 });

 1 var arr = [{name:‘Jack‘, delay: 200}, 
 2            {name:‘Mike‘, delay: 100}, 
 3            {name:‘Freewind‘, delay: 300}];
 4  
 5 async.forEach(arr, function(item, callback) { 
 6     log(’1.1 enter: ‘ + item.name); 
 7     setTimeout(function(){ 
 8         log(’1.1 handle: ‘ + item.name); 
 9         callback(); 
10     }, item.delay); 
11 }, function(err) { 
12     log(’1.1 err: ‘ + err); 
13 });

它将打出如下结果：

42.244> 1.1 enter: Jack 
42.245> 1.1 enter: Mike 
42.245> 1.1 enter: Freewind 
42.350> 1.1 handle: Mike 
42.445> 1.1 handle: Jack 
42.554> 1.1 handle: Freewind 
42.554> 1.1 err: undefined

这个函数还有一个衍生函数

eachLimit(arr, limit, iterator, callback)

最前面的数据是当前的时间值（秒.毫秒），从中可以看到各异步操作是并行执行的。

如果想同步执行，需要使用forEachSeries函数，它与forEach的用法一模一样，只是执行时是一个一个来的。这里就不给例子了。

当集合中元素很多，既不想一次全部并行操作，又不想一个一个按顺序来，可以使用forEachLimit函数。它可以设定一批处理几个，每一批内并行执行，批与批之间顺序执行。

1 async.forEachLimit(arr, 2, function(item, callback) { 
2     log(’1.5 enter: ‘ + item.name); 
3     setTimeout(function(){ 
4         log(’1.5 handle: ‘ + item.name); 
5         callback(null, item.name); 
6     }, item.delay); 
7 }, function(err) { 
8     log(’1.5 err: ‘ + err); 
9 });

打印结果如下：

42.247> 1.5 enter: Jack 
42.248> 1.5 enter: Mike 
42.351> 1.5 handle: Mike 
42.352> 1.5 enter: Freewind 
42.461> 1.5 handle: Jack 
42.664> 1.5 handle: Freewind 
42.664> 1.5 err: undefined

详情请参考https://github.com/freewind/async_demo/blob/master/forEach.js

2.map(arr, iterator, callback)　　遍历集合产生新的结果集合

map的重点是转换，即把集合中的元素通过异步操作转为另一个对象，最后可以得到转换后的对象数组。它也提供了并行与顺序执行两种方式。

这里给一个示例，给集合中的每个元素以异步方式增加!：

 1 var arr = [{name:‘Jack‘, delay:200}, {name:‘Mike‘, delay: 100}, {name:‘Freewind‘, delay:300}, {name:‘Test‘, delay: 50}];
 2 async.map(arr, function(item, callback) { 
 3     log(’1.1 enter: ‘ + item.name); 
 4     setTimeout(function() { 
 5         log(’1.1 handle: ‘ + item.name); 
 6         callback(null, item.name+’!!!’); 
 7     }, item.delay); 
 8 }, function(err,results) { 
 9     log(’1.1 err: ‘, err); 
10     log(’1.1 results: ‘, results); 
11 });

显示结果如下：

54.569> 1.1 enter: Jack 
54.569> 1.1 enter: Mike 
54.569> 1.1 enter: Freewind 
54.569> 1.1 enter: Test 
54.629> 1.1 handle: Test 
54.679> 1.1 handle: Mike 
54.789> 1.1 handle: Jack 
54.879> 1.1 handle: Freewind 
54.879> 1.1 err: 
54.879> 1.1 results: [ ‘Jack!!!‘, ‘Mike!!!‘, ‘Freewind!!!‘, ‘Test!!!‘ ]

详情请参考：https://github.com/freewind/async_demo/blob/master/map.js

3.filter(arr, iterator(item, callback(test)), callback(results))　　

　reject(arr, iterator(item, callback(test)), callback(results))　　数组过滤

使用异步操作对集合中的元素进行筛选。需要注意的是，iterator的callback只有一个参数，只能接收true或false。

对于出错，该函数没有做出任何处理，直接由nodejs抛出。所以需要注意对Error的处理。

提供了并行与顺序执行两种方式。

并行示例，找到所有>=3的元素：

1 async.filter([1,2,3,4,5], function(item, callback) { 
2     log(’1.1 enter: ‘ + item); 
3     setTimeout(function() { 
4         log(’1.1 test: ‘ + item); 
5         callback(item>=3); 
6     }, 200); 
7 }, function(results) { 
8     log(’1.1 results: ‘, results); 
9 });

打印结果如下：

16.739> 1.1 enter: 1 
16.749> 1.1 enter: 2 
16.749> 1.1 enter: 3 
16.749> 1.1 enter: 4 
16.749> 1.1 enter: 5 
16.749> 1.3 enter: 1 
16.949> 1.1 test: 1 
16.949> 1.1 test: 2 
16.949> 1.1 test: 3 
16.949> 1.1 test: 4 
16.949> 1.1 test: 5 
16.949> 1.1 results: [ 3, 4, 5 ]

可见找到了满足条件的所有元素。

如果需要顺序执行，可以使用filterSeries函数，它的用法与filter一样。

更多详细示例：https://github.com/freewind/async_demo/blob/master/filter_reject.js

reject与filter相似，只是行为正好相反。当条件为true时，它将丢弃相应的元素。它也提供了并行与顺序执行两种方式。

更多详细示例：https://github.com/freewind/async_demo/blob/master/filter_reject.js

async.js 学习教程（二）,古老的榕树,5-wow.com

郑重声明：本站内容如果来自互联网及其他传播媒体，其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享，并不代表本站赞同其观点和对其真实性负责，也不构成任何其他建议。

async.js 学习教程（二）