文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

promise.all怎么实现

2023-07-02 08:55

关注

本篇内容主要讲解“promise.all怎么实现”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“promise.all怎么实现”吧!

何为Promise.all?

Promise.all 是 es6 Promise 对象上的一个方法,它的功能就是将多个Promise实例包装成一个promise实例。以下是 MDN 对 Promise.all 的描述:

Promise.all() 方法接收一个 promise 的 iterable 类型(注:Array,Map,Set都属于ES6的iterable类型)的输入,并且只返回一个Promise实例, 那个输入的所有 promise 的 resolve 回调的结果是一个数组。这个Promise的 resolve 回调执行是在所有输入的 promise 的 resolve 回调都结束,或者输入的 iterable 里没有 promise 了的时候。它的 reject 回调执行是,只要任何一个输入的 promise 的 reject 回调执行或者输入不合法的 promise 就会立即抛出错误,并且reject的是第一个抛出的错误信息。

我戴上我的300度近视眼镜,仔细地提取出这段描述中的关键字

原生 Promise.all 测试

咱先看看原生的Promise.all的是啥效果。

const p1 = Promise.resolve('p1')const p2 = new Promise((resolve, reject) => {  setTimeout(() => {    resolve('p2 延时一秒')  }, 1000)})const p3 = new Promise((resolve, reject) => {  setTimeout(() => {    resolve('p3 延时两秒')  }, 2000)})const p4 = Promise.reject('p4 rejected')const p5 = new Promise((resolve, reject) => {  setTimeout(() => {    reject('p5 rejected 延时1.5秒')  }, 1500)})// 所有Promise实例都成功Promise.all([p1, p2, p3])  .then(res => {    console.log(res)  })  .catch(err => console.log(err)) // 2秒后打印 [ 'p1', 'p2 延时一秒', 'p3 延时两秒' ]  // 一个Promise实例失败Promise.all([p1, p2, p4])  .then(res => {    console.log(res)  })  .catch(err => console.log(err)) // p4 rejected  // 一个延时失败的Promise Promise.all([p1, p2, p5])  .then(res => {    console.log(res)  })  .catch(err => console.log(err)) // 1.5秒后打印 p5 rejected  // 两个Promise实例失败Promise.all([p1, p4, p5])  .then(res => {    console.log(res)  })  .catch(err => console.log(err)) // p4 rejected

注意

上面 p4p5 在未传入 Promise.all 时需要注释掉,因为一个调用了 rejectPromise 实例如果没有使用 .catch() 方法去捕获错误会报错。但如果 Promise 实例定义了自己的 .catch,就不会触发 Promise.all.catch() 方法。

OK,理论存在,实践开始!

手动实现Promise.all

Promise.MyAll = function (promises) {  return new Promise((resolve, reject) => {  })}
Promise.MyAll = function (promises) {  let arr = []  return new Promise((resolve, reject) => {    promises.forEach((item, i) => {      Promise.resolve(item).then(res => {        arr[i] = res      })    })   })}
if (arr.length === promises.length) resolve(arr)

咱仔细想想 Promise 使用来干嘛的 —— 处理异步任务。对呀,异步任务很多都需要花时间呀,如果这些 Promise 中最后一个先完成呢?那 arr 数组不就只有最后一项了,前面的所有项都是 empty。所以这里咱们应该创建一个计数器,每有一个 Promise 实例成功,计数器加一:

Promise.MyAll = function (promises) {  let arr = [],    count = 0  return new Promise((resolve, reject) => {    promises.forEach((item, i) => {      Promise.resolve(item).then(res => {        arr[i] = res        count += 1        if (count === promises.length) resolve(arr)      })    })  })}
Promise.MyAll = function (promises) {  let arr = [],    count = 0  return new Promise((resolve, reject) => {    promises.forEach((item, i) => {      Promise.resolve(item).then(res => {        arr[i] = res        count += 1        if (count === promises.length) resolve(arr)      }).catch(reject)    })  })}

第二种写法就是给 .then() 方法传入第二个参数,这个函数是处理错误的回调函数:

Promise.MyAll = function (promises) {  let arr = [],    count = 0  return new Promise((resolve, reject) => {    promises.forEach((item, i) => {      Promise.resolve(item).then(res => {        arr[i] = res        count += 1        if (count === promises.length) resolve(arr)      }, reject)    })  })}

测试案例

致此 Promise.all 大功告成,赶紧拿来测试一下(摩拳擦掌):

const p1 = Promise.resolve('p1')const p2 = new Promise((resolve, reject) => {  setTimeout(() => {    resolve('p2 延时一秒')  }, 1000)})const p3 = new Promise((resolve, reject) => {  setTimeout(() => {    resolve('p3 延时两秒')  }, 2000)})const p4 = Promise.reject('p4 rejected')const p5 = new Promise((resolve, reject) => {  setTimeout(() => {    reject('p5 rejected 延时1.5秒')  }, 1500)})// 所有 Promsie 都成功Promise.MyAll([p1, p2, p3])  .then(res => console.log(res))  .catch(err => console.log(err)) // 2秒后打印 [ 'p1', 'p2 延时一秒', 'p3 延时两秒' ]  // 一个 Promise 失败Promise.MyAll([p1, p2, p4])  .then(res => console.log(res))  .catch(err => console.log(err)) // p4 rejected  // 一个延时失败的 PromisePromise.MyAll([p1, p2, p5])  .then(res => console.log(res))  .catch(err => console.log(err)) // 1.5秒后打印 p5 rejected 延时1.5秒 // 两个失败的 PromisePromise.MyAll([p1, p4, p5])  .then(res => console.log(res))  .catch(err => console.log(err)) // p4 rejected

“OhOhOhOh~~~~”,与原生的 Promise.all运行结果不能说很像,只能说一模一样。老话说的好,趁热打铁——正在火候上。我打开某个学习网站(MDN Web Docs (mozilla.org)),了解到 Promise 对象用于同时处理多个 Promise 的方法还有 Promise.racePromise.anyPromise.allSettle。从小老师就教会了咱们举一反三,仔细看了这三个方法的描述之后,我还真给反出来了????。

Promise.race

Promise.race 从字面意思理解就是赛跑,以状态变化最快的那个 Promise 实例为准,最快的 Promise 成功 Promise.race 就成功,最快的 Promise 失败 Promise.race 就失败。

咱来看看原生 Promise.race 效果

原生 Promise.race 测试

const p1 = Promise.resolve('p1')const p2 = new Promise((resolve, reject) => {  setTimeout(() => {    resolve('p2 延时一秒')  }, 1000)})const p3 = new Promise((resolve, reject) => {  setTimeout(() => {    resolve('p3 延时两秒')  }, 2000)})const p4 = Promise.reject('p4 rejected')const p5 = new Promise((resolve, reject) => {  setTimeout(() => {    reject('p5 rejected 延时1秒')  }, 1500)})// p1无延时,p2延时1s,p3延时2sPromise.race([p1, p2, p3])  .then(res => console.log(res))  .catch(err => console.log(err)) // p1// p4无延时rejectPromise.race([p4, p2, p3])  .then(res => console.log(res))  .catch(err => console.log(err)) // p4 rejected  // p5 延时1.5秒reject,p2延时1sPromise.race([p5, p2, p3])  .then(res => console.log(res))  .catch(err => console.log(err)) // 1s后打印: p2 延时一秒

理论存在,实践开始

手写Promise.race

整体流程与 Promise 差不多,只是对数组中的 Promise 实例处理的逻辑不一样,这里我们需要将最快改变状态的 Promise 结果作为 Promise.race 的结果,相对来说就比较简单了,代码如下:

Promise.MyRace = function (promises) {  return new Promise((resolve, reject) => {    // 这里不需要使用索引,只要能循环出每一项就行    for (const item of promises) {      Promise.resolve(item).then(resolve, reject)    }  })}

测试案例

还是刚才几个案例,咱就不重复写了????

// p1无延时,p2延时1s,p3延时2sPromise.MyRace([p1, p2, p3])  .then(res => console.log(res))  .catch(err => console.log(err)) // p1// p4无延时rejectPromise.MyRace([p4, p2, p3])  .then(res => console.log(res))  .catch(err => console.log(err)) // p4 rejected  // p5 延时1.5秒reject,p2延时1sPromise.MyRace([p5, p2, p3])  .then(res => console.log(res))  .catch(err => console.log(err)) // 1s后打印: p2 延时一秒

可以看到,结果与原生的 Promise.race 是一致的,成功!

Promise.any

Promise.anyPromise.all 可以看做是相反的。Promise.any 中只要有一个 Promise 实例成功就成功,只有当所有的 Promise 实例失败时 Promise.any 才失败,此时Promise.any 会把所有的失败/错误集合在一起,返回一个失败的 promise AggregateError类型的实例。MDN 上说这个方法还处于试验阶段,如果 node 或者浏览器版本过低可能无法使用,各位看官自行测试下。

原生 Promise.any 测试

const p1 = Promise.resolve('p1')const p2 = new Promise((resolve, reject) => {  setTimeout(() => {    resolve('p2 延时一秒')  }, 1000)})const p3 = new Promise((resolve, reject) => {  setTimeout(() => {    resolve('p3 延时两秒')  }, 2000)})const p4 = Promise.reject('p4 rejected')const p5 = new Promise((resolve, reject) => {  setTimeout(() => {    reject('p5 rejected 延时1.5秒')  }, 1500)})// 所有 Promise 都成功Promise.any([p1, p2, p3])  .then(res => console.log(res))  .catch(err => console.log(err)) // p1  // 两个 Promise 成功Promise.any([p1, p2, p4])  .then(res => console.log(res))  .catch(err => console.log(err)) // p1// 只有一个延时成功的 PromisePromise.any([p2, p4, p5])  .then(res => console.log(res))  .catch(err => console.log(err)) // p2 延时1秒// 所有 Promise 都失败Promise.any([p4, p5])  .then(res => console.log(res))  .catch(err => console.log(err)) // AggregateError: All promises were rejected

可以看出,如果 Promise.any 中有多个成功的 Promise 实例,则以最快成功的那个结果作为自身 resolve 的结果。

OK,理论存在,实践开始

手写Promise.any

Promise.MyAny = function (promises) {  return new Promise((resolve, reject) => {    promises.forEach((item, i) => {    })  })}
Promise.MyAny = function (promises) {  let arr = [],    count = 0  return new Promise((resolve, reject) => {    promises.forEach((item, i) => {      Promise.resolve(item).then(resolve, err => {        arr[i] = { status: 'rejected', val: err }        count += 1        if (count === promises.length) reject(new Error('没有promise成功'))      })    })  })}

这里我没有使用 MDN 上规定的 AggregateError 实例,手写嘛,随心所欲一点,写自己看着舒服的????

测试案例

// 所有 Promise 都成功Promise.MyAny([p1, p2, p3])  .then(res => console.log(res))  .catch(err => console.log(err)) // p1  // 两个 Promise 成功Promise.MyAny([p1, p2, p4])  .then(res => console.log(res))  .catch(err => console.log(err)) // p1// 只有一个延时成功的 PromisePromise.MyAny([p2, p4, p5])  .then(res => console.log(res))  .catch(err => console.log(err)) // p2 延时1秒// 所有 Promise 都失败Promise.MyAny([p4, p5])  .then(res => console.log(res))  .catch(err => console.log(err)) // 没有promise成功

Promise.allSettled

有时候,咱代码人总是会有点特殊的需求:如果咱希望一组 Promise 实例无论成功与否,都等它们异步操作结束了在继续执行下一步操作,这可如何是好?于是就出现了 Promise.allSettled

原生 Promise.allSettled 测试

const p1 = Promise.resolve('p1')const p2 = new Promise((resolve, reject) => {  setTimeout(() => {    resolve('p2 延时一秒')  }, 1000)})const p3 = new Promise((resolve, reject) => {  setTimeout(() => {    resolve('p3 延时两秒')  }, 2000)})const p4 = Promise.reject('p4 rejected')const p5 = new Promise((resolve, reject) => {  setTimeout(() => {    reject('p5 rejected 延时1.5秒')  }, 1500)})// 所有 Promise 实例都成功Promise.allSettled([p1, p2, p3])  .then(res => console.log(res))  .catch(err => console.log(err)) // [//   { status: 'fulfilled', value: 'p1' },//   { status: 'fulfilled', value: 'p2 延时一秒' },//   { status: 'fulfilled', value: 'p3 延时两秒' }// ]// 有一个 Promise 失败Promise.allSettled([p1, p2, p4])  .then(res => console.log(res))  .catch(err => console.log(err))// [//   { status: 'fulfilled', value: 'p1' },//   { status: 'fulfilled', value: 'p2 延时一秒' },//   { status: 'rejected' , value: 'p4 rejected' }// ]// 所有 Promise 都失败Promise.allSettled([p4, p5])  .then(res => console.log(res))  .catch(err => console.log(err))// [//   { status: 'rejected', reason: 'p4 rejected' },//   { status: 'rejected', reason: 'p5 rejected 延时1.5秒' }// ]

可以看到,与 Promise.any 类似,Promise.allSettled 也给所有收集到的结果打上了标记。而且 Promise.allSettled 是不会变成 rejected 状态的,不管一组 Promise 实例的各自结果如何,Promise.allSettled 都会转变为 fulfilled 状态。

OK,理论存在,实践开始

手写 Promise.allSettled

咱就是说,得用个数组把所有的 Promise 实例的结果(无论成功与否)都收集起来,判断收集完了(所有 Promise 实例状态都改变了),咱就将这个收集到的结果 resolve 掉。收集成功 Promise 结果的逻辑咱们在 Promise.all 中实现过,收集失败 Promise 结果咱们在 Promise.any 中处理过。这波,这波是依葫芦画瓢——照样。

Promise.MyAllSettled = function (promises) {  let arr = [],    count = 0  return new Promise((resolve, reject) => {    promises.forEach((item, i) => {      Promise.resolve(item).then(res => {        arr[i] = { status: 'fulfilled', val: res }        count += 1        if (count === promises.length) resolve(arr)      }, (err) => {        arr[i] = { status: 'rejected', val: err }        count += 1        if (count === promises.length) resolve(arr)      })    })  })}

这代码,逻辑上虽说没问题,但各位优秀的程序员们肯定是看不顺眼的,怎么会有两段重复的代码捏,不行,咱得封装一下。

Promise.MyAllSettled = function (promises) {  let arr = [],    count = 0  return new Promise((resolve, reject) => {    const processResult = (res, index, status) => {      arr[index] = { status: status, val: res }      count += 1      if (count === promises.length) resolve(arr)    }    promises.forEach((item, i) => {      Promise.resolve(item).then(res => {        processResult(res, i, 'fulfilled')      }, err => {        processResult(err, i, 'rejected')      })    })  })}

perfect,俗话说得好:没病走两步。老样子,给代码跑几个案例。

测试案例

// 所有 Promise 实例都成功Promise.MyAllSettled([p1, p2, p3])  .then(res => console.log(res))  .catch(err => console.log(err)) // [//   { status: 'fulfilled', value: 'p1' },//   { status: 'fulfilled', value: 'p2 延时一秒' },//   { status: 'fulfilled', value: 'p3 延时两秒' }// ]// 有一个 MyAllSettled 失败Promise.allSettled([p1, p2, p4])  .then(res => console.log(res))  .catch(err => console.log(err))// [//   { status: 'fulfilled', value: 'p1' },//   { status: 'fulfilled', value: 'p2 延时一秒' },//   { status: 'rejected' , value: 'p4 rejected' }// ]// 所有 MyAllSettled 都失败Promise.allSettled([p4, p5])  .then(res => console.log(res))  .catch(err => console.log(err))// [//   { status: 'rejected', reason: 'p4 rejected' },//   { status: 'rejected', reason: 'p5 rejected 延时1.5秒' }// ]

到此,相信大家对“promise.all怎么实现”有了更深的了解,不妨来实际操作一番吧!这里是编程网网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯