并发控制是限制同时执行的异步任务数量，通过scheduler类或asyncpool函数实现，确保系统资源不被耗尽，提升稳定性和性能。
在JavaScript中处理多个异步任务时，直接并发执行所有任务可能导致资源耗尽、接口限流或性能下降。因此，需要一种机制来控制同时运行的任务数量，这就是并发控制的核心目标。实现一个异步任务调度器，可以有效管理任务的执行节奏，既能提升效率，又能避免系统过载。
什么是并发控制？
并发控制指的是限制同时执行的异步任务数量。例如，有10个网络请求，但只允许最多3个同时进行，其余任务需等待前面的任务完成后再启动。这种模式常见于爬虫抓取、批量上传、接口调用等场景。
实现一个简单的任务调度器
我们可以通过封装一个 Scheduler 类来实现并发控制。该类接收最大并发数，并提供添加任务的方法，确保任何时候正在执行的任务不超过设定上限。
示例代码：
立即学习“Java免费学习笔记（深入）”；
class Scheduler {
constructor(maxConcurrent) {
this.maxConcurrent = maxConcurrent;
this.running = 0;
this.queue = [];
}
// 添加异步任务
addTask(task) {
return new Promise((resolve, reject) => {
this.queue.push({ task, resolve, reject });
this.run();
});
}
// 执行任务
async run() {
if (this.running >= this.maxConcurrent || this.queue.length === 0) return;
this.running++;
const { task, resolve, reject } = this.queue.shift();
try {
const result = await task();
resolve(result);
} catch (error) {
reject(error);
} finally {
this.running--;
this.run(); // 尝试执行下一个任务
}
}
}使用示例：
```javascript const scheduler = new Scheduler(2); // 最多同时执行2个任务// 模拟异步任务
function createTask(id, delay) {
return () => new Promise(resolve => {
setTimeout(() => {
console.log(任务 ${id} 完成);
resolve(id);
}, delay);
});
}
// 添加多个任务 scheduler.addTask(createTask(1, 1000)); scheduler.addTask(createTask(2, 500)); scheduler.addTask(createTask(3, 800)); scheduler.addTask(createTask(4, 300));
<p>输出顺序会根据执行时间动态变化，但始终保证最多只有两个任务在运行。</p>
<H3>基于 Promise 的并发控制函数</H3>
<p>除了类的形式，也可以写一个通用的高阶函数，用于包装任务数组并控制并发。</p>
```javascript
async function asyncPool(tasks, maxConcurrent) {
const results = [];
const executing = [];
for (const task of tasks) {
const p = Promise.resolve().then(task);
results.push(p);
const e = p.finally(() => {
executing.splice(executing.indexOf(e), 1);
});
executing.push(e);
if (executing.length >= maxConcurrent) {
await Promise.race(executing);
}
}
return Promise.all(results);
}使用方式：
```javascript const tasks = [ () => fetch('/api/1').then(r => r.json()), () => fetch('/api/2').then(r => r.json()), () => fetch('/api/3').then(r => r.json()) ];asyncPool(tasks, 2).then(results => { console.log('全部完成', results); });
<p>这个方法利用 <strong>Promise.race</strong> 监听最早完成的任务，一旦有空位就继续提交新任务，从而实现平滑的调度。</p> <H3>关键点总结</H3> <ul> <li>并发控制能防止资源争用和服务器压力过大</li> <li>通过维护运行中任务计数和任务队列可实现精细控制</li> <li>Scheduler 模式适合长期任务管理，asyncPool 更适用于一次性批处理</li> <li>利用 Promise.finally 清理执行队列是关键技巧</li> <li>注意错误捕获，避免某个任务失败导致整个调度中断</li> </ul> <p>基本上就这些。掌握并发控制不仅能提升程序稳定性，还能优化用户体验。实际项目中可根据需求扩展超时控制、优先级排序等功能。不复杂但容易忽略细节。
