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

看过 (一)的同学一定觉得这个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);
})
}

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都会继续划分,因为我们这里是并发的删除,我们是用方法就是用问题一来解决这些所有的东西!

以上就是两章内容,过几天上第三章内容,基本上就解决所有可能遇到的问题了!以上这些方法足以解决上百同时的并发查询!我指单个请求中包含的!

关键字:node.js, node, mongodb, return


本文来自互联网用户投稿,文章观点仅代表作者本人,不代表本站立场,不承担相关法律责任。如若转载,请注明出处。 如若内容造成侵权/违法违规/事实不符,请点击【内容举报】进行投诉反馈!

立即
投稿

微信公众账号

微信扫一扫加关注

返回
顶部