函数柯里化不直接实现并发限制，但能通过预设并固化最大并发数来提升并发控制逻辑的清晰度与复用性：先传入limit生成定制化调度器，再传入任务数组执行，如createLimiter(2)返回可并发执行2个任务的函数。
函数柯里化本身不直接实现并发限制，但它能优雅地预设并固化最大并发数，让并发控制逻辑更清晰、复用性更强。核心在于：把“最大并发数”作为第一层参数固定下来，返回一个已配置好限制的异步任务调度器。
柯里化如何绑定并发数
柯里化把多参数函数拆成单参数函数链。对并发控制器而言，就是先传入 limit，返回一个“记住这个 limit”的新函数，后续只接收任务列表即可执行：
- 调用
createLimiter(3)得到一个“最多同时跑 3 个任务”的函数 - 这个函数再接收任务数组（如
[api1, api2, ...]），自动按 3 并发执行 - 不同场景可复用同一柯里化工厂，比如
createLimiter(1)用于敏感操作，createLimiter(5)用于批量读取
实际写法示例
下面是一个基于 Promise + 队列的柯里化并发控制器：
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 < limit && index < tasks.length) {
runNext();
}
// 等待全部完成
await new Promise(resolve => {
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);
配合工厂函数提升可维护性
柯里化常与任务工廠结合，避免提前触发请求：
立即学习“Java免费学习笔记（深入）”；
- 任务必须是
() => Promise形式，而不是已执行的 Promise - 柯里化后的函数只负责调度，不关心任务内容，职责分离更干净
- 可轻松组合其他逻辑，比如加日志、重试、超时包装后再传入
对比直接传参的差异
不柯里化时每次都要写 runTasks(tasks, 3)；柯里化后变成 limiter3(tasks)，语义更明确，也方便注入配置或做单元测试模拟。
