内容简介:前几天看了作者
前几天看了作者 zz_jesse 的 写给新手前端的各种文件上传攻略,从小图片到大文件断点续传 ,学习了很多有关上传的知识点。但在大文件分片上传一块,作者有提及分片上传需要做并发限制处理,但他的demo并没有做。抱着学习的心态,我又去网上学习了一番。。
Promise.all()
Promise.all() 方法用于将多个 Promise 实例,包装成一个新的 Promise 实例。
const p = Promise.all([p1, p2, p3]);
上面代码中, Promise.all() 方法接受一个数组作为参数,p1、p2、p3都是 Promise 实例,如果不是,就会先调用下面讲到的 Promise.resolve 方法,将参数转为 Promise 实例,再进一步处理。另外, Promise.all() 方法的参数可以不是数组,但必须具有 Iterator 接口,且返回的每个成员都是 Promise 实例。
p的状态由p1、p2、p3决定,分成两种情况。
(1)只有p1、p2、p3的状态都变成 fulfilled ,p的状态才会变成 fulfilled ,此时p1、p2、p3的返回值组成一个数组,传递给p的回调函数。
(2)只要p1、p2、p3之中有一个被 rejected ,p的状态就变成 rejected ,此时第一个被 reject 的实例的返回值,会传递给p的回调函数。
Code
const requestsLimit = (list, limit, asyncHandle) => {
return new Promise(resolve => {
let _limit = limit;
let recordList = []; // 记录异步操作
let index = 0;
let listCopy = [].concat(list);
let asyncList = []; // 正在进行的所有并发异步操作
const asyncFunc = () => {
while(_limit--) {
const data = listCopy.shift()
if (data) asyncList.push(asyncHandle(data, index++));
}
Promise.all(asyncList).then(response => {
// 监听并记录每一次请求的结果
recordList = recordList.concat(response.filter(item => item));
if (listCopy.length !== 0) {
_limit = limit;
asyncList = [];
asyncFunc() // 数组还未迭代完,递归继续进行迭代
} else {
// 所有并发异步操作都完成后,本次并发控制迭代完成,返回记录结果
resolve(recordList)
}
})
}
asyncFunc()
})
}
var dataLists = [1,2,3,4,5,6,7,8];
requestsLimit(dataLists, 3, (item, index) => {
return new Promise(resolve => {
// 执行异步处理
setTimeout(() => {
// 筛选异步处理的结果
console.log(index)
if (item % 2 === 0) resolve({ item, index })
else resolve()
}, Math.random() * 5000)
});
}).then(response => {
console.log('finish', response)
})
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
逆向工程权威指南
Dennis Yurichev(丹尼斯) / 安天安全研究与应急处理中心 / 人民邮电出版社 / 2017-3-1 / 168
逆向工程是一种分析目标系统的过程,旨在于识别系统的各组件以及组件间关系,以便于通过其它形式、或在较高的抽象层次上,重建系统的表征。 本书专注于软件的逆向工程,是写给初学者的一本经典指南。全书共分为12个部分,共102章,涉及X86/X64、ARM/ARM-64、MIPS、Java/JVM等重要话题,详细解析了Oracle RDBMS、Itanium、软件狗、LD_PRELOAD、栈溢出、EL......一起来看看 《逆向工程权威指南》 这本书的介绍吧!