Nodejs異步流程框架async

miya 發(fā)布于2019-08-23 17:59 / 1552人閱讀

摘要：如果任何函數(shù)發(fā)生錯誤，會立刻執(zhí)行回調(diào)函數(shù)，并返回錯誤信息若沒有發(fā)生錯誤，則會再所有函數(shù)執(zhí)行完畢之后用回掉函數(shù)將結(jié)果返回。

Async的簡單介紹：

Async是一個流程控制工具包，提供了直接而強大的異步功能?；贘avascript為Node.js設(shè)計，同時也可以直接在瀏覽器中使用。Async提供了大約20個函數(shù)，包括常用的
map, reduce, filter, forEach等，異步流程控制模式包括，串行(series)，并行(parallel)，瀑布(waterfall)等。
https://github.com/caolan/async

我們常用的是以下四種：

串行無關(guān)聯(lián)
串行有關(guān)聯(lián)
并行無關(guān)聯(lián)
智能控制

1.async.series：串行無關(guān)聯(lián)：
多個函數(shù)或方法要依次執(zhí)行，但是他們之間并沒有什么聯(lián)系，只有先后的順序，比如我要寫一個文件，寫完之后像用戶發(fā)送郵件，這兩者之間沒有必然的聯(lián)系，但是發(fā)郵件必須在寫文件完成之后。
async里有一個方法series可以實現(xiàn)這一流程,代碼實現(xiàn)如下：

var async = require("async");
console.time("series");
async.series({
    one: function(callback) {
        callback(null, "one");//callback("i am err","one");異常處理
    },
    two: function(callback) {
        callback(null, "two");

    },
}, function(error, result) {
    //最后結(jié)果
    console.log("error: " + error);
    console.log("result: " + result);
    console.timeEnd("series");
});

//  error: null
//  result: [object Object]
//  series: 4.472ms

2.async.waterfall：串行有關(guān)聯(lián) 瀑布流函數(shù),串行執(zhí)行數(shù)組中的每一個函數(shù)最后執(zhí)行回調(diào)。語法：async.waterfall(tasks,callback) 第一個參數(shù)tasks是一個數(shù)組，數(shù)組包含的是需要依次執(zhí)行的函數(shù)。
第二個參數(shù)為回調(diào)函數(shù)，當(dāng)瀑布流函數(shù)（即tasks數(shù)組中的函數(shù)）執(zhí)行出現(xiàn)錯誤時會執(zhí)行這個回調(diào)函數(shù)并將錯誤信息返回,當(dāng)瀑布流函數(shù)無錯誤時，會在執(zhí)行完tasks數(shù)組中包含的函數(shù)后執(zhí)行這個回調(diào)函數(shù)。
用法示例：一般用法：

async.waterfall([
    myFirstFun,
    mySecondFun,
    myLastFun
],function(err,result) {  // result回調(diào)函數(shù)
    //  result 相當(dāng)于tasks數(shù)組中最后一個函數(shù)（myLastFun）的返回值done
    console.log(result);   //  myLastFun
})
function myFirstFun(callback) {
    callback(null,"one","two");
}
function mySecondFun(arg1,arg2,callback) {
    //  arg1 相當(dāng)于 "one" ,arg2 相當(dāng)于 "two"
    callback(null,"three");
}
function myLastFun(arg1,callback) {
    //  arg1 相當(dāng)于 "three"
    callback(null,"done");
}

3.async.parallel：并行無關(guān)聯(lián) task并行運行函數(shù)集合，而不必等到上一個函數(shù)完成。如果任何函數(shù)發(fā)生錯誤，會立刻執(zhí)行回調(diào)函數(shù)，并返回錯誤信息；若沒有發(fā)生錯誤，則會再所有tasks函數(shù)執(zhí)行完畢之后用回掉函數(shù)將結(jié)果返回。
語法：async.parallel(tasks,callback) 代碼示例：

async.parallel([
    function(callback) {
        setTimeout(function() {
            callback(null, "one");
        }, 200);
    },
    function(callback) {
        setTimeout(function() {
            callback(null, "two");
        }, 100);
    }
],function(err, results) {
    console.log(result)}
);

4.async.auto：智能控制
以上都是純串行傳并行，但是當(dāng)一個場景里，需要使用串行也需要使用并行的時候，雖然分別寫能解決，但是效率不是很高，維護性也不是很好，auto可以解決這一問題。
如下場景：
從某處取得數(shù)據(jù)
在硬盤上建立一個新的目錄
將數(shù)據(jù)寫入到目錄下某文件
發(fā)送郵件，將文件以附件形式發(fā)送給其它人。
可以知道1與2可以并行執(zhí)行，3需要等1和2完成，4要等3完成。
使用auto來解決

var async = require("async");
console.time("auto");
async.auto({
    getData: function(callback) {
        setTimeout(function() {
            console.log("1.1: got data");
            callback(null, "mydata");
        }, 300);
    },
    makeFolder: function(callback) {
        setTimeout(function() {
            console.log("1.1: made folder");
            callback(null, "myfolder");
        }, 200);
    },
    writeFile: ["getData", "makeFolder", function(callback) {
        setTimeout(function() {
            console.log("1.1: wrote file");
            callback(null, "myfile");
        }, 300);
    }],
    emailFiles: ["writeFile", function(callback, results) {
        console.log("emailed file: ", results.writeFile);
        callback(null, results.writeFile);
    }]
}, function(err, results) {
    console.log("err: ", err);
    console.log("results: ", results);
    console.timeEnd("auto");
});

結(jié)果如下
1.1: made folder
1.1: got data
1.1: wrote file
emailed file:  myfile
err:  null
results:  { makeFolder: "myfolder",
  getData: "mydata",
  writeFile: "myfile",
  emailFiles: "myfile" 
}
auto: 650.972ms

GPU云服務(wù)器云服務(wù)器 nodejs循環(huán)異步 js異步框架異步協(xié)程框架 nodejs框架

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/104488.html

發(fā)表評論

登陸后可評論

0條評論

miya

男|高級講師

我要關(guān)注我要私信

TA的文章

uTools實用工具提高跨電腦平臺數(shù)據(jù)同步多個日常辦公效率工具集

閱讀 2056·2021-09-07 10:24
Tooltip組件拆解

閱讀 2114·2019-08-30 15:55
理解 CSS 布局和 BFC

閱讀 2070·2019-08-30 15:43
深入理解css之line-height

閱讀 695·2019-08-29 15:25
safari瀏覽器fixed后，被軟鍵盤遮蓋的問題—【未解決】

閱讀 1097·2019-08-29 12:19
小程序采坑記

閱讀 1964·2019-08-23 18:32
Nodejs異步流程框架async

閱讀 1553·2019-08-23 17:59
bootstrap datetimepicker日期插件美化

閱讀 971·2019-08-23 12:22

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Nodejs異步流程框架async

相關(guān)文章

**異步發(fā)展流程 —— 異步編程的終極大招 async/await**

**從零開始nodejs系列文章**

Generator：同步代碼書寫異步情懷

node.js中文資料導(dǎo)航

**下一代基于Koa的NodeJS全棧開發(fā)框架**

發(fā)表評論

0條評論

miya

男|高級講師

TA的文章

uTools實用工具提高跨電腦平臺數(shù)據(jù)同步多個日常辦公效率工具集

Tooltip組件拆解

理解 CSS 布局和 BFC

深入理解css之line-height

safari瀏覽器fixed后，被軟鍵盤遮蓋的問題—【未解決】

小程序采坑記