JavaScript并发控制_javascript多任务处理-js教程-PHP中文网

JavaScript并发控制_javascript多任务处理

夢幻星辰

发布： 2025-12-05 18:40:03

原创

432人浏览过

JavaScript通过事件循环实现异步任务的并发控制，使用concurrentControl函数限制最大并发数，避免资源耗尽；该函数利用Promise和索引追踪任务执行，确保最多同时运行指定数量的任务，完成后汇总结果，适用于批量请求、文件上传等场景，提升应用稳定性。

javascript并发控制_javascript多任务处理

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

上述代码保证最多同时运行两个任务，当前任务完成后才会拉起下一个待执行任务。

Unity3D游戏开发之Asset server服务器搭建中文WORD版

本文档主要讲述的是Unity3D游戏开发之Asset server服务器搭建；Asset Server是目前unity内部自带的资源版本管理工具，类似于我们平时所熟知的SVN，perForce，但对于目前的Unity，Asset Server要比SVN和perForce等版本控制软件要好用一些，因为Unity3.x版本对于SVN等软件的支持并不是很好，在多人协同工作时，经常会发生数据丢失等情况。因此，本文重点介绍一下Asser Server的搭建方法。至于日常用法，其实与SVN等软件的用法非常相似，所以在

查看详情

结合 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 个请求同时发出，既高效又安全。

基本上就这些。不复杂但容易忽略细节。掌握并发控制对构建健壮的异步应用很有帮助。

以上就是JavaScript并发控制_javascript多任务处理的详细内容，更多请关注php中文网其它相关文章！