在非阻塞IO下的nodejs下的同步并行 ES6的 promise 從入門深入（二）

verano 發(fā)布于2019-06-26 17:00 / 870人閱讀

摘要：現(xiàn)在我們要用的重點就是我們的，這是一個能讓函數(shù)并行的，可以基于多個。非常有用啊先上一個錯誤的代碼這時候我們得到的就是數(shù)字了，而不是一個數(shù)組，這就是神奇所在。

看過 (一)的同學一定覺得這個Promise很簡單，好像沒什么可以用的地方，但是事實上，它的用處非常大啊，尤其是在nodejs上，愈加重要，雖然已經(jīng)有大量的庫實現(xiàn)了對Promise的封裝了，不過我還是更傾向用原生的node來實現(xiàn)對Promise的實現(xiàn)。
現(xiàn)在我們要用的重點就是我們的Promise.all，這是一個能讓函數(shù)并行的promise，可以基于多個Promise。我們講介紹下簡單的應用和在復雜的環(huán)境下的一些使用方法.

兩個demo函數(shù)
function demo1(){
    return Promise.resolve(1);
}
function demo2(){
    return Promise.resolve(2);
}
function demo3(){
    return Promise.all([demo1(),demo2()]);
}

demo3().then(result=>{
    console.log(result)
}).catch(err=>{
    console.log(err)
})

基于以上的代碼，你將得到一個數(shù)組，獲得[1,2]，其原理很簡單，就是讓兩個函數(shù)同時開始異步操作，就是并行拉，然后返回的數(shù)據(jù)存放在一個數(shù)組，并且是按順序的！??！而且注意，在Promise.all中，如果其中一個操作獲得了reject或是error，那么我們都將得到一個reject，并且，這兩個操作的最終時長是取決于兩者中最長的那個，直到兩個都完成了才能返回結(jié)果。非常有用?。?！

先上一個錯誤的代碼

function demo1(){
    return Promise.resolve(1);
}
function demo2(){
    return Promise.reject(2);
}
function demo3(){
    return Promise.all([demo1(),demo2()]);
}

demo3().then(result=>{
    console.log(result)
}).catch(err=>{
    console.log(err)
})

這時候我們得到的就是數(shù)字2了，而不是一個數(shù)組，這就是神奇所在。
再最后一個例子就是Promise.race 這個簡單介紹以下就好了，因為這個不常用，想想也知道你說你要執(zhí)行兩個操作，只要完成其中一個就返回其中一個的結(jié)果，除非是賽跑，不然這個東西有什么意義，比較難想象有能運用的地方，我寫了這么就的Promise就是沒用遇到過了！下面是例子

function demo1(){
    return Promise.resolve(1);
}
function demo2(){
    return Promise.resolve(2);
}
function demo3(){
    return Promise.race([demo1(),demo2()]);
}

demo3().then(result=>{
    console.log(result)
}).catch(err=>{
    console.log(err)
})

我們得到的結(jié)果將會是1或2，跟前面的reject一樣，如果其中之一來reject，或是異常，一定會被catch捕獲！這是毋庸置疑的，但前提是在兩個之一都沒有完成的情況下才能被捕獲，所以是十分困難的。

運用以上的所有內(nèi)容就基本能解決我們在項目中的大部分問題了，但是偶爾我們會遇到比較難的問題，下面拿我使用mongodb時候遇到的問題來講解。大家可以忽略這些細節(jié)，更關(guān)注用法！

問題1 是：我要同時查10筆操作，可是我們該如何操作

    
    
  
 //這是10筆要查的數(shù)據(jù)集合
    var array = [1,2,3,4,5,6,7,8,9,10];
    //這里大家使用自己的數(shù)據(jù)庫進行案例
    var model = mongoose.model("demo");
    Promise.all([array.map(i=>{
        return new Promise((resolve,reject)=>{
            resolve(demo(i))
        })
    })]).then(result=>{
        //獲得十筆查詢后的記錄
        console.log(result);
    })
    
    
    function demo(name){
        return model.find({name:name}).exec();
    }

問題2:我該如何使用混合同步并發(fā)執(zhí)行先查詢圖片名字，然后記錄下來并且刪除這些圖片

//模擬查詢圖片
function queryImgs(){
    return new Promise((resolve,reject)=>{
    //返回查詢結(jié)果
        resolve(1);
    })
}
//模擬刪除圖片
function deleteImg(imgs){
    return new Promise((resolve,reject)=>{
            resolve(1);
        })
}
//模擬記錄圖片
function recordImg(imgs){
    return new Promise((resolve,reject)=>{
            resolve(1);
        })
}

function delAndRecord(imgs){
    return Promise.all([deleteImgs(imgs),recordImgs(imgs)]);
}

queryImgs().then(delAndRecord).then(result=>{
    console.log(result)
}).catch(err=>{
    console.log(err)
})

當然，我們這邊的deleteImgs和recordImgs都會繼續(xù)劃分，因為我們這里是并發(fā)的刪除，我們是用方法就是用問題一來解決這些所有的東西！

以上就是兩章內(nèi)容，過幾天上第三章內(nèi)容，基本上就解決所有可能遇到的問題了！以上這些方法足以解決上百同時的并發(fā)查詢！我指單個請求中包含的！

云服務器 GPU云服務器 slb下的ecs數(shù)據(jù)同步下的嵌套規(guī)則 linux下的命令 linux下的插件

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

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

發(fā)表評論

登陸后可評論

0條評論

verano

男|高級講師

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

TA的文章

數(shù)據(jù)集成工具的使用（一）---Sqoop 從理論學習到熟練使用

閱讀 2397·2021-10-09 09:41
基于UCOSII的RS485通信(STM32F107)

閱讀 3200·2021-09-26 09:46
Win11正式版將於10月5日推出：Win10用戶可免費升級?。ǜ较螺d）

閱讀 846·2021-09-03 10:34
搬瓦工，DC3機房CN2 VPS簡單測評（USCA_3）

閱讀 3185·2021-08-11 11:22
前端面試題-url、href、src

閱讀 3380·2019-08-30 14:12
MobX詳解（三）：MobX基礎

閱讀 721·2019-08-26 11:34
2020京東秋招筆試編程（姓名排序）

閱讀 3353·2019-08-26 11:00
Node.js 高級進階之 fs 文件模塊學習

閱讀 1784·2019-08-26 10:26

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

資訊專欄INFORMATION COLUMN

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

在非阻塞IO下的nodejs下的同步并行 ES6的 promise 從入門深入（二）

相關(guān)文章