JavaScript并发控制_异步任务调度算法

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(); // 尝试执行下一个任务
    }
  }
}

<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);
}

<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>基本上就这些。掌握并发控制不仅能提升程序稳定性，还能优化用户体验。实际项目中可根据需求扩展超时控制、优先级排序等功能。不复杂但容易忽略细节。