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

2016-05-16 11:18:00

看过 (一)的同学一定觉得这个Promise很简单，好像没什么可以用的地方，但是事实上，它的用处非常大啊，尤其是在nodejs上，愈加重要，虽然已经有大量的库实现了对Promise的封装了，不过我还是更倾向用原生的node来实现对Promise的实现。
现在我们要用的重点就是我们的Promise.all，这是一个能让函数并行的promise，可以基于多个Promise。我们讲介绍下简单的应用和在复杂的环境下的一些使用方法.

两个demo函数
function demo1(){
return Promise.resolve(1);
}
function demo2(){
return Promise.resolve(2);
}
function demo3(){
return Promise.all([demo1(),demo2()]);
}

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

基于以上的代码，你将得到一个数组，获得[1,2]，其原理很简单，就是让两个函数同时开始异步操作，就是并行拉，然后返回的数据存放在一个数组，并且是按顺序的！！！而且注意，在Promise.all中，如果其中一个操作获得了reject或是error，那么我们都将得到一个reject，并且，这两个操作的最终时长是取决于两者中最长的那个，直到两个都完成了才能返回结果。非常有用啊！！

先上一个错误的代码

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

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

这时候我们得到的就是数字2了，而不是一个数组，这就是神奇所在。
再最后一个例子就是Promise.race 这个简单介绍以下就好了，因为这个不常用，想想也知道你说你要执行两个操作，只要完成其中一个就返回其中一个的结果，除非是赛跑，不然这个东西有什么意义，比较难想象有能运用的地方，我写了这么就的Promise就是没用遇到过了！下面是例子

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

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

我们得到的结果将会是1或2，跟前面的reject一样，如果其中之一来reject，或是异常，一定会被catch捕获！这是毋庸置疑的，但前提是在两个之一都没有完成的情况下才能被捕获，所以是十分困难的。

运用以上的所有内容就基本能解决我们在项目中的大部分问题了，但是偶尔我们会遇到比较难的问题，下面拿我使用mongodb时候遇到的问题来讲解。大家可以忽略这些细节，更关注用法！

问题1 是：我要同时查10笔操作，可是我们该如何操作

//这是10笔要查的数据集合
var array = [1,2,3,4,5,6,7,8,9,10];
//这里大家使用自己的数据库进行案例
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:我该如何使用混合同步并发执行先查询图片名字，然后记录下来并且删除这些图片

//模拟查询图片
function queryImgs(){
return new Promise((resolve,reject)=>{
//返回查询结果
resolve(1);
})
}
//模拟删除图片
function deleteImg(imgs){
return new Promise((resolve,reject)=>{
resolve(1);
})
}
//模拟记录图片
function recordImg(imgs){
return new Promise((resolve,reject)=>{
resolve(1);
})
}