JavaScript并发控制模式

JavaScript中通过限制异步任务并发数避免资源过载,常用方法包括:1. 手动用Promise维护队列和活跃任务数;2. 用async/await结合Promise.race实现简化控制;3. 使用p-limit等第三方库。

javascript并发控制模式

JavaScript中的并发控制主要用于限制同时执行的任务数量,避免资源过载或接口限流。由于JavaScript是单线程语言,所谓的“并发”更多是指异步任务的协调与调度,特别是在处理大量Promise或异步请求时,合理的控制机制能提升稳定性和性能。

1. 并发控制的基本场景

当你需要发起100个HTTP请求时,如果全部同时发出,可能造成浏览器阻塞、服务端压力过大或触发限流策略。理想做法是只允许固定数量(如5个)请求同时进行,完成一个后再发起下一个。

常见应用场景包括:

批量上传或下载文件 爬虫抓取多个页面 定时轮询多个接口 资源密集型计算任务调度

2. 使用Promise + 队列实现并发控制

通过维护一个任务队列和活跃任务数,可以手动控制并发。核心思路是:当活跃任务少于最大并发数时,从队列中取出任务执行。

立即学习“Java免费学习笔记(深入)”;

function concurrencyControl(tasks, maxConcurrent) {  let index = 0;  let activeCount = 0;  let resolvedCount = 0;  const results = Array(tasks.length);  return new Promise((resolve) => {    function next() {      if (index >= tasks.length && activeCount === 0) {        resolve(results);        return;      }      while (activeCount < maxConcurrent && index  {            results[i] = { status: 'fulfilled', value: res };          })          .catch((err) => {            results[i] = { status: 'rejected', reason: err };          })          .finally(() => {            activeCount--;            next();          });      }    }    next();  });}

使用方式:

千帆大模型平台 千帆大模型平台

面向企业开发者的一站式大模型开发及服务运行平台

千帆大模型平台 0 查看详情 千帆大模型平台

const tasks = Array(10).fill().map((_, i) => () =>  fetch(`/api/data/${i}`).then(res => res.json()));concurrencyControl(tasks, 3).then(results => {  console.log('所有任务完成:', results);});

3. 基于async/await的简化实现

利用async函数和递归调用,可以让逻辑更清晰。

async function runWithLimit(tasks, limit) {  const results = [];  const executing = [];  for (const task of tasks) {    const p = task().then(res => {      results.push(res);      return res;    });        executing.push(p);    if (executing.length >= limit) {      await Promise.race(executing); // 等待任意一个完成      executing.splice(executing.indexOf(p), 1);    }  }  await Promise.all(executing); // 等待剩余任务  return results;}

这个版本使用Promise.race来释放已完成的任务槽位,适合对顺序要求不高的场景。

4. 使用第三方库(如p-limit)

实际项目中推荐使用成熟库,例如 p-limit,简洁且经过充分测试。

import pLimit from 'p-limit';const limit = pLimit(3); // 最大并发3const promises = urls.map(url =>  limit(() => fetch(url).then(r => r.text())));const results = await Promise.all(promises);

它内部实现了高效的调度逻辑,支持错误传播和取消操作,适合生产环境。

基本上就这些常见的并发控制模式。关键在于理解任务调度机制,根据场景选择手动实现或使用工具库。不复杂但容易忽略细节,比如错误处理和结果顺序。合理控制并发能显著提升程序健壮性。

以上就是JavaScript并发控制模式的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/293530.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年11月4日 21:38:51
下一篇 2025年11月4日 21:40:06

相关推荐

发表回复

登录后才能评论
关注微信