Nodejs異步流程框架async

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

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

Async的簡(jiǎn)單介紹：

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

我們常用的是以下四種：

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

1.async.series：串行無(wú)關(guān)聯(lián)：
多個(gè)函數(shù)或方法要依次執(zhí)行，但是他們之間并沒(méi)有什么聯(lián)系，只有先后的順序，比如我要寫(xiě)一個(gè)文件，寫(xiě)完之后像用戶(hù)發(fā)送郵件，這兩者之間沒(méi)有必然的聯(lián)系，但是發(fā)郵件必須在寫(xiě)文件完成之后。
async里有一個(gè)方法series可以實(shí)現(xiàn)這一流程,代碼實(shí)現(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ù)組中的每一個(gè)函數(shù)最后執(zhí)行回調(diào)。語(yǔ)法：async.waterfall(tasks,callback) 第一個(gè)參數(shù)tasks是一個(gè)數(shù)組，數(shù)組包含的是需要依次執(zhí)行的函數(shù)。
第二個(gè)參數(shù)為回調(diào)函數(shù)，當(dāng)瀑布流函數(shù)（即tasks數(shù)組中的函數(shù)）執(zhí)行出現(xiàn)錯(cuò)誤時(shí)會(huì)執(zhí)行這個(gè)回調(diào)函數(shù)并將錯(cuò)誤信息返回,當(dāng)瀑布流函數(shù)無(wú)錯(cuò)誤時(shí)，會(huì)在執(zhí)行完tasks數(shù)組中包含的函數(shù)后執(zhí)行這個(gè)回調(diào)函數(shù)。
用法示例：一般用法：

async.waterfall([
    myFirstFun,
    mySecondFun,
    myLastFun
],function(err,result) {  // result回調(diào)函數(shù)
    //  result 相當(dāng)于tasks數(shù)組中最后一個(gè)函數(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：并行無(wú)關(guān)聯(lián) task并行運(yùn)行函數(shù)集合，而不必等到上一個(gè)函數(shù)完成。如果任何函數(shù)發(fā)生錯(cuò)誤，會(huì)立刻執(zhí)行回調(diào)函數(shù)，并返回錯(cuò)誤信息；若沒(méi)有發(fā)生錯(cuò)誤，則會(huì)再所有tasks函數(shù)執(zhí)行完畢之后用回掉函數(shù)將結(jié)果返回。
語(yǔ)法：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)一個(gè)場(chǎng)景里，需要使用串行也需要使用并行的時(shí)候，雖然分別寫(xiě)能解決，但是效率不是很高，維護(hù)性也不是很好，auto可以解決這一問(wèn)題。
如下場(chǎng)景：
從某處取得數(shù)據(jù)
在硬盤(pán)上建立一個(gè)新的目錄
將數(shù)據(jù)寫(xiě)入到目錄下某文件
發(fā)送郵件，將文件以附件形式發(fā)送給其它人。
可以知道1與2可以并行執(zhí)行，3需要等1和2完成，4要等3完成。
使用auto來(lái)解決

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)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://m.hztianpu.com/yun/104488.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

miya

男|高級(jí)講師

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

TA的文章

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

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

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

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

閱讀 763·2019-08-29 15:25
safari瀏覽器fixed后，被軟鍵盤(pán)遮蓋的問(wèn)題—【未解決】

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

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

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

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

成人无码视频,亚洲精品久久久久av无码,午夜精品久久久久久毛片,亚洲中文字幕日韩无码

資訊專(zhuān)欄INFORMATION COLUMN

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

Nodejs異步流程框架async

相關(guān)文章

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

**從零開(kāi)始nodejs系列文章**

Generator：同步代碼書(shū)寫(xiě)異步情懷

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

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

發(fā)表評(píng)論

0條評(píng)論

miya

男|高級(jí)講師

TA的文章

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

Tooltip組件拆解

理解 CSS 布局和 BFC

深入理解css之line-height

safari瀏覽器fixed后，被軟鍵盤(pán)遮蓋的問(wèn)題—【未解決】

小程序采坑記