深入學習nodejs中的async模塊的使用方法
最近在學習nodejs，這兩天學習了async模塊這個地方知識點挺多的，所以，今天添加一點小筆記。
async模塊是為了解決嵌套金字塔,和異步流程控制而生.常用的方法介紹
npm 安裝好async模塊,然后引入就可以使用 var async = require('async');
1. series(tasks,[callback])
多個函數(shù)從上到下依次執(zhí)行,相互之間沒有數(shù)據(jù)交互
var task1 =function(callback){
console.log("task1");
callback(null,"task1")
}
var task2 =function(callback){
console.log("task2");
callback(null,"task2")
}
var task3 =function(callback){
console.log("task3");
callback(null,"task3")
}
async.series([task1,task2,task3],function(err,result){
console.log("series");
if (err) {
console.log(err);
}
console.log(result);
})
運行結果:
如果中途發(fā)生錯誤,則將錯誤傳遞到回調(diào)函數(shù),并停止執(zhí)行后面的函數(shù)
var task1 =function(callback){
console.log("task1");
callback(null,"task1")
}
var task2 =function(callback){
console.log("task2");
callback("err","task2")
}
var task3 =function(callback){
console.log("task3");
callback(null,"task3")
}
async.series([task1,task2,task3],function(err,result){
console.log("series");
if (err) {
console.log(err);
}
console.log(result);
})
運行結果:
2.parallel(tasks,[callback])
多個函數(shù)并行執(zhí)行,不會等待其他函數(shù)
var task1 =function(callback){
console.log("task1");
setTimeout(function(){
callback(null,"task1")
},5000);
}
var task2 =function(callback){
console.log("task2");
setTimeout(function(){
callback(null,"task2")
},1000);
}
var task3 =function(callback){
console.log("task3");
setTimeout(function(){
callback(null,"task3")
},3000);
}
console.time("parallel方法");
async.parallel([task1,task2,task3],function(err,result){
console.log("parallel");
if (err) {
console.log(err);
}
console.log(result);
console.timeEnd("parallel方法");
})
運行結果:
3個函數(shù)分別延遲5000ms,1000ms,3000ms 結果5000ms就執(zhí)行完畢.
如果中途出錯,則立即將err和值傳到最終的回調(diào)函數(shù),其他未執(zhí)行完畢的函數(shù)將不再執(zhí)行,但是要占一個位置
var task1 =function(callback){
console.log("task1");
setTimeout(function(){
callback(null,"task1")
},5000);
}
var task2 =function(callback){
console.log("task2");
setTimeout(function(){
callback("errmessage","task2")
},3000);
}
var task3 =function(callback){
console.log("task3");
setTimeout(function(){
callback(null,"task3")
},1000);
}
console.time("parallel方法");
async.parallel([task1,task2,task3],function(err,result){
console.log("parallel");
if (err) {
console.log(err);
}
console.log(result);
console.timeEnd("parallel方法");
})
運行結果:
3.waterfall(tasks,[callback]) :瀑布流
依次執(zhí)行,前一個函數(shù)的輸出為后一個函數(shù)的輸入
var task1 =function(callback){
console.log("task1");
callback(null,"11")
}
var task2 =function(q,callback){
console.log("task2");
console.log("task1函數(shù)傳入的值: "+q);
callback(null,"22")
}
var task3 =function(q,callback){
console.log("task3");
console.log("task2函數(shù)傳入的值: "+q);
callback(null,"33")
}
console.time("waterfall方法");
async.waterfall([task1,task2,task3],function(err,result){
console.log("waterfall");
if (err) {
console.log(err);
}
console.log("result : "+result);
console.timeEnd("waterfall方法");
})
執(zhí)行結果:
如果中途出現(xiàn)錯誤,后面的函數(shù)將不在執(zhí)行,之前執(zhí)行的結果和錯誤信息將直接傳到最終的回調(diào)函數(shù)
var task1 =function(callback){
console.log("task1");
callback(null,"11")
}
var task2 =function(q,callback){
console.log("task2");
console.log("task1函數(shù)傳入的值: "+q);
callback("errmessage","22")
}
var task3 =function(q,callback){
console.log("task3");
console.log("task2函數(shù)傳入的值: "+q);
callback(null,"33")
}
console.time("waterfall方法");
async.waterfall([task1,task2,task3],function(err,result){
console.log("waterfall");
if (err) {
console.log(err);
}
console.log("result : "+result);
console.timeEnd("waterfall方法");
})
運行結果:
4.parallelLimit(tasks,limit,[callback])
和parallel類似,只是limit參數(shù)限制了同時并發(fā)執(zhí)行的個數(shù),不再是無限并發(fā)
var task1 =function(callback){
console.log("task1");
setTimeout(function(){
callback(null,"task1")
},5000);
}
var task2 =function(callback){
console.log("task2");
setTimeout(function(){
callback(null,"task2")
},3000);
}
var task3 =function(callback){
console.log("task3");
setTimeout(function(){
callback(null,"task3")
},4000);
}
console.time("parallelLimit方法");
async.parallelLimit([task1,task2,task3], 2, function(err,result){
console.log("parallelLimit");
if (err) {
console.log(err);
}
console.log(result);
console.timeEnd("parallelLimit方法");
})
運行結果:
三個函數(shù)分別是延遲5000ms,3000ms,4000ms結果執(zhí)行時間為什么是7000ms呢
因為首先執(zhí)行函數(shù)1和2,
3秒后函數(shù)2執(zhí)行完畢,這個時候函數(shù)3開始執(zhí)行,
5秒后函數(shù)1執(zhí)行完畢,函數(shù)3還有2秒,
7秒后函數(shù)3執(zhí)行完畢.
5.auto(tasks,[callback])
多個函數(shù)有數(shù)據(jù)交互,有的并行,有的依次執(zhí)行
console.time("auto方法");
async.auto({
task1: function(callback){
console.log("tsak1");
setTimeout(function(){
callback(null, 'task11', 'task12');
},2000);
},
task2: function(callback){
console.log('task2');
setTimeout(function(){
callback(null, 'task2');
},3000);
},
task3: ['task1', 'task2', function(callback, results){
console.log('task3');
console.log('task1和task2運行結果: ',results);
setTimeout(function(){
callback(null, 'task3');
},1000);
}],
task4: ['task3', function(callback, results){
console.log('task4');
console.log('task1,task2,task3運行結果: ',results);
setTimeout(function(){
callback(null, {'task41':results.task3, 'task42':'task42'});
},1000);
}]
}, function(err, results) {
console.log('err :', err);
console.log('最終results : ', results);
console.timeEnd("auto方法");
});
運行結果:
5秒運行完畢,
函數(shù)1和2并行,3秒執(zhí)行完畢,
函數(shù)1和2執(zhí)行完畢后,函數(shù)3,4依次執(zhí)行共計5秒.
6.whilst(test,fn,[callback])
相當于while循環(huán),fn函數(shù)里不管是同步還是異步都會執(zhí)行完上一次循環(huán)才會執(zhí)行下一次循環(huán),對異步循環(huán)很有幫助,
test是條件,為true時執(zhí)行fn里的方法
var datalist = [{number:10},{number:20},{number:30},{number:40},{number:50}];
var count = 0;
var test = function () {
return count<datalist.length;
};
var fn = function(callback){
console.log(datalist[count].number);
setTimeout(function () {
count++;
callback();
},1000)
};
async.whilst(test,fn,function(err){
if(err){
console.log(err);
}
console.log('whilst結束');
});
運行結果:
7.doWhilst
和whilst類似,和do-while一個意思,首先執(zhí)行一次fn,再判斷,和whilst相比它把fn和test位置交換了而已.
until和whilst相反,當test判斷為false的時候執(zhí)行fn里的方法,為true時跳出,
doUntil與doWhilst相反.
8.forever(fn,errback)
forever就是無限循環(huán)了.只有當中途出現(xiàn)錯誤的時候才會停止
var count = 0;
async.forever(function(callback){
console.log(count);
count++;
if (count>10) {
callback("errmessage");
return;
}
setTimeout(function () {
callback();
},1000)
},
function(err){
console.log(err);
});
運行結果:
9.compose(fn1,fn2,fn3...)
這個方法會創(chuàng)建一個異步的集合函數(shù),執(zhí)行的順序是倒序.前一個fn的輸出是后一個fn的輸入.有數(shù)據(jù)交互
var task1 =function(m,callback){
console.log("task1");
setTimeout(function(){
callback(null,m*2)
},1000);
}
var task2 =function(m,callback){
console.log("task2");
setTimeout(function(){
callback(null,m+3)
},1000);
}
var task3 =function(m,callback){
console.log("task3");
setTimeout(function(){
callback(null,m*5)
},1000);
}
console.time("compose方法");
var com = async.compose(task3,task2,task1);
com(2,function(err,result){
if (err) {
console.log(err);
}
console.log(result);
console.timeEnd("compose方法");
})
運行結果:
相當于 var m=2; (m*2+3)*5 =35;
在我的項目開發(fā)中waterfall用的最多.
更多方法詳情 : https://www.npmjs.com/package/async
以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
Node.js操作Firebird數(shù)據(jù)庫教程
這篇文章主要為大家分享了Node.js操作Firebird數(shù)據(jù)庫教程，思路清晰便于大家理解，感興趣的小伙伴們可以參考一下2016-03-03
本篇文章主要介紹了Node.js 沙箱環(huán)境 ，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-05-05
這篇文章主要介紹了node.js中的fs.close方法使用說明,本文介紹了fs.close方法說明、語法、接收參數(shù)、使用實例和實現(xiàn)源碼,需要的朋友可以參考下2014-12-12
下面小編就為大家?guī)硪黄獎?chuàng)建簡單的node服務器實例(分享)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-06-06
在 Node.js 中啟動一個 WebSocket 服務器并使其在后臺持續(xù)運行,你可以使用幾種方法,下面是一種常見的方法,通過創(chuàng)建一個簡單的 WebSocket 服務器并使用 node 命令直接運行它,同時確保它在后臺運行,需要的朋友可以參考下2024-10-10
詳解如何在Node.js中正確處理async/await及數(shù)組迭代
在使用?Node.js?開發(fā)應用程序時,我們常常需要處理異步操作,在這種情況下,我們通常會使用?async/await?語法來簡化異步編程的復雜性,下面小編就來和大家聊聊如何正確處理async/await吧2024-12-12
我的Node.js學習之路（三）--node.js作用、回調(diào)、同步和異步代碼 以及事件循環(huán)
本篇文章主要介紹了node.js的幾個重要的知識點：node.js作用、回調(diào)、同步和異步代碼 以及事件循環(huán)2014-07-07
Express 是一個簡潔而靈活的 node.js Web應用框架, 提供一系列強大特性幫助你創(chuàng)建各種Web應用。下面我們將逐步分析下，各位不要輕易離開2014-07-07
Nodejs讀寫流流的傳輸過程默認是以buffer的形式傳輸?shù)?除非你給他設置其他編碼形式, 小伙伴可以參考下。2016-03-03
使用 Node.js 實現(xiàn)圖片的動態(tài)裁切及算法實例代碼詳解
這篇文章主要介紹了使用 Node.js 實現(xiàn)圖片的動態(tài)裁切功能，本文通過實例代碼給大家介紹的非常詳細，具有一定的參考借鑒價值,需要的朋友可以參考下2018-09-09