手写原理 | Promise.all

Promise.all 方法接收一个promise的iterable类型(比如:Array,Map,Set)的输入,并且只返回一个Promise实例,如果所有的promise都是resolve状态,value就为结果数组,结果的顺序与传入顺序一致,如果promise中有reject,就会抛出错误,reason为抛出的是第一个reject的信息

应用场景:在请求数据的过程中,偶尔会遇到发送多个请求并根据请求顺序获取和使用数据的场景

实现思路及注意点

  • 输入promises可以是一个iterator类型的参数,不一定需要局限在array(好多手写一上来就判断是不是array)
  • 如果iterator为空,resolve返回空数组
  • 非Promise实例的需要经过Promise.resolve包裹
  • 如果都会resolve,输出的结果数组必须和原顺序一致,并不是谁先执行完谁先进入结果数组
  • 返回一个Promise实例可以调用then和catch方法,then里面为保持原顺序的数组,catch里面则为最早reject的返回值
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
function myPromiseAll(promises) {
return new Promise((resolve, reject) => {
const promiseResults = [];
// 迭代的顺序
let iteratorIndex = 0;
// 用于记录已经完成的数量,注意这个不是顺序
let fullCount = 0;
// 迭代开始
for (let promise of promises) { // for of就是用于遍历可迭代对象的
// for of 是顺序执行的
let resultIndex = iteratorIndex;
iteratorIndex++;

// 非Promise实例的需要经过Promise.resolve包裹
Promise.resolve(promise).then(res => {
promiseResults[resultIndex] = res;
// then后表示完成
fullCount++;

// Iterator接口无法单纯根据length和size判断长度
if (fullCount === iteratorIndex) {
resolve(promiseResults);
}
}).catch(err => {
reject(err);
})
}

// 如果iterator为空,resolve返回空数组
if (iteratorIndex === 0) {
resolve(promiseResults);
}
})
}

// test
var p1 = Promise.resolve(3);
var p2 = 1337;
var p3 = new Promise((resolve, reject) => {
setTimeout(resolve, 100, 'foo');
});

var p = myPromiseAll([p1, p2, p3]); // Promise {<fulfilled>: [3, 1337, "foo"]}
p.then(values => {
console.log(values); // [3, 1337, "foo"]
})