JavaScript通过事件循环实现异步任务的并发控制，使用concurrentControl函数限制最大并发数，避免资源耗尽；该函数利用Promise和索引追踪任务执行，确保最多同时运行指定数量的任务，完成后汇总结果，适用于批量请求、文件上传等场景，提升应用稳定性。
JavaScript 是单线程语言，但通过事件循环和异步机制实现了看似“并发”的多任务处理。虽然不能像多线程语言那样真正并行执行代码，但可以通过合理的方式控制异步任务的并发数量，避免资源耗尽或接口请求过多导致的问题。
为什么需要并发控制
在实际开发中，可能会遇到以下场景：
- 批量上传大量文件，同时发起所有请求会占用过多带宽或触发浏览器限制
- 爬取多个网页数据，需限制同时进行的请求数量
- 处理大量异步任务，防止主线程阻塞或内存溢出
如果不加控制，一次性启动成百上千个 Promise，可能导致系统资源紧张甚至崩溃。因此，需要一种机制来限制同时执行的任务数，这就是并发控制的核心目标。
实现一个简单的并发控制器
我们可以封装一个函数，接收任务列表和最大并发数，在不超过限制的前提下按顺序执行任务。
立即学习“Java免费学习笔记（深入）”；
function concurrentControl(tasks, maxConcurrent) {return new Promise((resolve) => {
let index = 0;
let completed = 0;
let result = [];
if (tasks.length === 0) return resolve(result);
function runTask() {
if (index >= tasks.length) return;
const currentIndex = index++;
const taskPromise = tasks[currentIndex]();
taskPromise.then(res => {
result[currentIndex] = res;
completed++;
if (completed === tasks.length) {
resolve(result);
} else {
runTask();
}
}).catch(err => {
console.error('Task failed:', err);
});
}
for (let i = 0; i runTask();
}
});
}
使用方式：
const sleep = (time) => () => new Promise(r => setTimeout(r, time));const tasks = [
sleep(1000),
sleep(500),
sleep(800),
sleep(300)
];
concurrentControl(tasks, 2).then(() => console.log('All done'));
上述代码保证最多同时运行两个任务，当前任务完成后才会拉起下一个待执行任务。
NetShop网店系统
下载
NetShop软件特点介绍： 1、使用ASP.Net(c#)2.0、多层结构开发 2、前台设计不采用任何.NET内置控件读取数据，完全标签化模板处理，加快读取速度3、安全的数据添加删除读取操作，利用存储过程模式彻底防制SQL注入式攻击4、前台架构DIV+CSS兼容IE6,IE7,FF等，有利于搜索引挚收录5、后台内置强大的功能，整合多家网店系统的功能，加以优化。6、支持三种类型的数据库：Acces
结合 async/await 简化逻辑
利用 async 函数可以让控制流更清晰。以下是改写版本：
async function concurrentControl(tasks, maxConcurrent) {const results = [];
let index = 0;
async function worker() {
while (index const i = index++;
try {
const result = await tasks[i]();
results[i] = result;
} catch (err) {
results[i] = err;
}
}
}
const workers = Array.from({ length: maxConcurrent }, () => worker());
await Promise.all(workers);
return results;
}
这个版本使用了多个“工作线程”（其实是协程）去消费任务队列，结构更简洁且易于理解。
实际应用场景举例
比如从多个 URL 获取数据：
const urls = ['https://api.example.com/data1',
'https://api.example.com/data2',
'https://api.example.com/data3'
];
const tasks = urls.map(url => () => fetch(url).then(r => r.json()));
concurrentControl(tasks, 3).then(results => {
console.log('所有响应:', results);
});
这样可以确保最多只有 3 个请求同时发出，既高效又安全。
基本上就这些。不复杂但容易忽略细节。掌握并发控制对构建健壮的异步应用很有帮助。
