扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
今天就跟大家聊聊有关node 中如何使用Async异步处理模块,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
创新互联公司是一家专业提供伊吾企业网站建设,专注与做网站、成都做网站、HTML5建站、小程序制作等业务。10年已为伊吾众多企业、政府机构等服务。创新互联专业的建站公司优惠进行中。
Async异步处理模块!
以下是小sam的理解:
安装很简单,就跟普通的安装模块一样就行了
这样就安装成功了! 接下来就是引用了,在代码里引用模块:
var async = require('async');
这样引用也就ok了!在代码后面就可以轻松的用async这个对像模块了!
查了下官方文档,这个模块的方法实在是太多了!看的眼花……
下面我们来谈谈小编觉得比较常用到的几个方法就好了
series
1.series(tasks, [callback]) 顺序执行数组、集合内的函数,当前面一个函数执行完成就会立即执行下一个函数,如果函数触发了错误,可以在callback函数中验证,否则会一直执行完成tasks
话多没用,代码才是亲爹
用例:
//tasks传的是一个数组函数 async.series([ function(callback) { // do some stuff ... callback(null, 'one'); }, function(callback) { // do some more stuff ... callback(null, 'two'); }], // optional callback //我觉得这里很重要err是上面两个函数的错误信息,而results这个参数是一个数组对象,它们的值是上面数组函数每个callback里面的参数。 function(err, results) { // results is now equal to ['one', 'two'] }); // an example using an object instead of an //下面的代码其实跟上面的差不多,只是stasks传的是对象而不是数组 async.series({ one: function(callback) { setTimeout(function() { callback(null, 1); }, 200); }, two: function(callback) { setTimeout(function() { callback(null, 2); }, 100); } }, function(err, results) { // results is now equal to: {one: 1, two: 2} });
parallel
2.parallel(tasks, [callback]) 并行执行数组、集合内的方法,不用等到前一个函数执行完再执行下一个函数,如果函数触发了错误,可以在callback函数中验证
async.parallel( [ function(callback) { setTimeout(function() { callback(null, 'one'); }, 200); }, function(callback) { setTimeout(function() { callback(null, 'two'); }, 100); } ], // optional callback function(err, results) { // the results array will equal ['one','two'] even thoug // the second function had a shorter timeout } );
parallelLimit
3.parallelLimit(tasks, limit, [callback]) 和2用法一样,只是多了一个任务数量限制,最多允许多少个任务在并行执行
whilst
4.whilst(test, fn, callback) 等同于while的用法,第一个参数为验证条件,第二个参数为执行函数,第三个参数为验证失败后回调函数,一般在做延迟动画用的比较多
var count = 0; async.whilst( function () { return count < 5; }, //验证成 功继续,失败进回调 function (callback) { count++; setTimeout(callback, 1000); }, function (err) { // 5 seconds have passed } );
waterfall
5.waterfall(tasks, [callback]) tasks依次运行,前一个函数的回调会作为后一个函数的参数,如果有任何任务通过一个错误的回调,下一个函数不执行
async.waterfall([ function(callback){ callback(null, 'one', 'two'); }, function(arg1, arg2, callback){ // arg1 now equals 'one' and arg2 nowequals 'two' callback(null, 'three'); }, function(arg1, callback){ // arg1 now equals 'three' callback(null, 'done'); } ], function (err, result) { // result now equals 'done' });
compose
6.compose(fn1, fn2...) 按顺序加入到队列中,按顺序执行,将上一个函数的结果作为下一个函数的值
function add1(n, callback) { setTimeout(function () { callback(null, n + 1); }, 10); } function mul3(n, callback) { setTimeout(function () { callback(null, n * 3); }, 10); } var add1mul3 = async.compose(mul3, add1); add1mul3(4, function (err, result) { // result now equals 15 });
看完上述内容,你们对node 中如何使用Async异步处理模块有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注创新互联行业资讯频道,感谢大家的支持。
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流