JavaScript 中函数柯里化怎么在异步任务并发限制中预设最大并发数-js教程-PHP中文网

函数柯里化不直接实现并发限制，但能通过预设并固化最大并发数来提升并发控制逻辑的清晰度与复用性：先传入limit生成定制化调度器，再传入任务数组执行，如createLimiter(2)返回可并发执行2个任务的函数。

javascript 中函数柯里化怎么在异步任务并发限制中预设最大并发数

函数柯里化本身不直接实现并发限制，但它能优雅地预设并固化最大并发数，让并发控制逻辑更清晰、复用性更强。核心在于：把“最大并发数”作为第一层参数固定下来，返回一个已配置好限制的异步任务调度器。

柯里化如何绑定并发数

柯里化把多参数函数拆成单参数函数链。对并发控制器而言，就是先传入 limit，返回一个“记住这个 limit”的新函数，后续只接收任务列表即可执行：

调用 createLimiter(3) 得到一个“最多同时跑 3 个任务”的函数
这个函数再接收任务数组（如 [api1, api2, ...]），自动按 3 并发执行
不同场景可复用同一柯里化工厂，比如 createLimiter(1) 用于敏感操作，createLimiter(5) 用于批量读取

实际写法示例

下面是一个基于 Promise + 队列的柯里化并发控制器：

Java Api Extractor

从 Java 项目中提取 Controller 层接口定义为 JSON 数据。

下载

const createLimiter = (limit) => {
  return async (tasks) => {
    const results = [];
    let running = 0;
    let index = 0;

    const runNext = async () => {
      if (index >= tasks.length) return;
      if (running >= limit) {
        await new Promise(resolve => setTimeout(resolve, 0));
        return runNext();
      }
      running++;
      const task = tasks[index++];
      try {
        const res = await task();
        results.push({ status: 'fulfilled', value: res });
      } catch (err) {
        results.push({ status: 'rejected', reason: err });
      } finally {
        running--;
        runNext();
      }
    };

    // 启动初始批次
    while (running  {
      const check = () => {
        if (running === 0 && index >= tasks.length) resolve();
        else setTimeout(check, 0);
      };
      check();
    });

    return results;
  };
};

// 使用：预设并发数为 2
const fetchWith2 = createLimiter(2);
fetchWith2([
  () => fetch('/api/a'),
  () => fetch('/api/b'),
  () => fetch('/api/c'),
  () => fetch('/api/d')
]).then(console.log);