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

Jrain 發(fā)布于2019-08-19 18:19 / 1164人閱讀

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

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

兩個(gè)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)
})

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

先上一個(gè)錯(cuò)誤的代碼

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í)候我們得到的就是數(shù)字2了，而不是一個(gè)數(shù)組，這就是神奇所在。
再最后一個(gè)例子就是Promise.race 這個(gè)簡單介紹以下就好了，因?yàn)檫@個(gè)不常用，想想也知道你說你要執(zhí)行兩個(gè)操作，只要完成其中一個(gè)就返回其中一個(gè)的結(jié)果，除非是賽跑，不然這個(gè)東西有什么意義，比較難想象有能運(yùn)用的地方，我寫了這么就的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é)果將會(huì)是1或2，跟前面的reject一樣，如果其中之一來reject，或是異常，一定會(huì)被catch捕獲！這是毋庸置疑的，但前提是在兩個(gè)之一都沒有完成的情況下才能被捕獲，所以是十分困難的。

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

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

    
    
  
 //這是10筆要查的數(shù)據(jù)集合
    var array = [1,2,3,4,5,6,7,8,9,10];
    //這里大家使用自己的數(shù)據(jù)庫進(jìn)行案例
    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)
})

當(dāng)然，我們這邊的deleteImgs和recordImgs都會(huì)繼續(xù)劃分，因?yàn)槲覀冞@里是并發(fā)的刪除，我們是用方法就是用問題一來解決這些所有的東西！

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