极乐门资源网 Design By www.ioogu.com
在网上看到这么一道题:
这道题跟鱼头这篇记录『什么是时间分片(Time Slicing)? 』有点相似,但不同的是这次是限制异步并发的数量。
所以话不多说,我们先来康康实现
首先我们来实现一个分割数组的函数~
const group = (list = [], max = 0) => { if (!list.length) { return list } let results = [] for (let i = 0, len = list.length; i < len; i += max) { results.push(list.slice(i, i + max)) } return results }
这里就是根据指定的并发数量来分割数组。主要就是 for
+ slice
,这没啥好说的
接下来我们再来一个用 async
+ await
实现的请求集合封装。
我们通过 for...of
去遍历每一个异步函数,然后用 async
+ await
确保函数的执行顺序,再用 try...catch
来保证即使 reject
报错也不会导致无法继续执行任务。
const requestHandler = async ( groupedUrl = [], callback = () => { } ) => { if (!groupedUrl.length) { callback() return groupedUrl } const newGroupedUrl = groupedUrl.map(fn => fn()) const resultsMapper = (results) => results.map(callback) const data = await Promise.allSettled(newGroupedUrl).then(resultsMapper) return data; }
接下来就是主函数
const sendRequest = async ( urls = [], max = 0, callback = () => { } ) => { if (!urls.length) { return urls } const groupedUrls = group(urls, max) const results = [] console.log('start !') for (let groupedUrl of groupedUrls) { try { const result = await requestHandler(groupedUrl, callback) results.push(result) console.log('go') } catch { } } console.log('done !') return results }
这里就是利用了 for
+ async
+ await
来限制并发。等每次并发任务结果出来之后再执行下一次的任务。
我们执行下栗子:
const p1 = () => new Promise((resolve, reject) => setTimeout(reject, 1000, 'p1')) const p2 = () => Promise.resolve(2) const p3 = () => new Promise((resolve, reject) => setTimeout(resolve, 2000, 'p3')) const p4 = () => Promise.resolve(4) const p5 = () => new Promise((resolve, reject) => setTimeout(reject, 2000, 'p5')) const p6 = () => Promise.resolve(6) const p7 = () => new Promise((resolve, reject) => setTimeout(resolve, 1000, 'p7')) const p8 = () => Promise.resolve(8) const p9 = () => new Promise((resolve, reject) => setTimeout(reject, 1000, 'p9')) const p10 = () => Promise.resolve(10) const p11 = () => new Promise((resolve, reject) => setTimeout(resolve, 2000, 'p10')) const p12 = () => Promise.resolve(12) const p13 = () => new Promise((resolve, reject) => setTimeout(reject, 1000, 'p11')) const p14 = () => Promise.resolve(14) const ps = [p1, p2, p3, p4, p5, p6, p7, p8, p9, p10, p11, p12, p13, p14] sendRequest(ps, 3, ({reason, value}) => { console.log(reason || value) })
OK,我们看到结果是如我们所愿的
极乐门资源网 Design By www.ioogu.com
极乐门资源网
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件!
如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
极乐门资源网 Design By www.ioogu.com
暂无JavaScript实现指定数量的并发限制的示例代码的评论...
RTX 5090要首发 性能要翻倍!三星展示GDDR7显存
三星在GTC上展示了专为下一代游戏GPU设计的GDDR7内存。
首次推出的GDDR7内存模块密度为16GB,每个模块容量为2GB。其速度预设为32 Gbps(PAM3),但也可以降至28 Gbps,以提高产量和初始阶段的整体性能和成本效益。
据三星表示,GDDR7内存的能效将提高20%,同时工作电压仅为1.1V,低于标准的1.2V。通过采用更新的封装材料和优化的电路设计,使得在高速运行时的发热量降低,GDDR7的热阻比GDDR6降低了70%。
更新日志
2024年11月16日
2024年11月16日
- 群星《歌手2024 第13期》[FLAC/分轨][325.93MB]
- 阿木乃《爱情买卖》DTS-ES【NRG镜像】
- 江蕾《爱是这样甜》DTS-WAV
- VA-Hair(OriginalBroadwayCastRecording)(1968)(PBTHAL24-96FLAC)
- 博主分享《美末2RE》PS5 Pro运行画面 玩家仍不买账
- 《双城之战2》超多新歌MV发布:林肯公园再次献声
- 群星《说唱梦工厂 第11期》[320K/MP3][63.25MB]
- 群星《说唱梦工厂 第11期》[FLAC/分轨][343.07MB]
- 群星《闪光的夏天 第5期》[320K/MP3][79.35MB]
- 秀兰玛雅.1999-友情人【大旗】【WAV+CUE】
- 小米.2020-我想在城市里当一个乡下人【滚石】【FLAC分轨】
- 齐豫.2003-THE.UNHEARD.OF.CHYI.3CD【苏活音乐】【WAV+CUE】
- 黄乙玲1986-讲什么山盟海誓[日本东芝版][WAV+CUE]
- 曾庆瑜1991-柔情陷阱[台湾派森东芝版][WAV+CUE]
- 陈建江《享受男声》DTS-ES6.1【WAV】