用es6类实现支持并发控制的任务队列，核心是维护待执行任务队列和有限活跃槽位，通过promise链与状态管理（maxconcurrency、running、queue）实现可控串行/并行调度。
<p>用 ES6 类实现一个支持并发控制的任务队列，核心是维护一个待执行任务队列 + 有限数量的“活跃执行槽位”，通过 Promise 链和状态管理来串行/并行可控地运行异步任务。</p> <h3>基础结构：任务存储与并发数控制</h3> <p>类需保存：<strong>最大并发数（maxConcurrency）</strong>、<strong>当前运行中任务数（running）</strong>、<strong>等待队列（queue）</strong>。每次添加任务不立即执行，而是入队；有空闲槽位时才从队首取任务执行。</p> <p>关键点：</p>
- 构造时指定 maxConcurrency，默认为 1（纯串行）
- running 初始为 0，每开始一个任务加 1，结束减 1
- 每个任务包装成返回 Promise 的函数，便于统一 await 和错误处理
添加任务：入队 + 尝试启动
提供 add() 方法接收一个异步函数（如 () => fetch('/api')），返回一个 Promise，让用户能 await 该任务结果。
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
实现逻辑：
- 将任务和一个 resolve/reject 控制器一起推入 queue 数组
- 调用 tryRun()：若 running
- 任务执行完毕（无论成功失败）必须调用 finish()，触发下一轮 tryRun()
执行调度：自动启停 + 错误透传
任务执行后需确保：
- Promise 正常 resolve 或 reject，结果/错误原样暴露给调用 add() 的地方
- 执行完必须调用 finish()，减少 running 并检查 queue 是否还有待办任务
- tryRun() 是递归驱动的核心：只要有空槽且有任务，就持续取、执行、减槽
示例 finish() 内部会做：running--; if (queue.length > 0) tryRun();
完整可运行类代码
以下是轻量、无依赖的实现：
<code class="js">class TaskQueue {
constructor(maxConcurrency = 1) {
this.maxConcurrency = Math.max(1, maxConcurrency);
this.running = 0;
this.queue = [];
}
add(taskFn) {
return new Promise((resolve, reject) => {
this.queue.push({ taskFn, resolve, reject });
this.tryRun();
});
}
tryRun() {
if (this.running >= this.maxConcurrency || this.queue.length === 0) return;
const { taskFn, resolve, reject } = this.queue.shift();
this.running++;
Promise.resolve()
.then(() => taskFn())
.then(result => {
resolve(result);
})
.catch(err => {
reject(err);
})
.finally(() => {
this.running--;
this.tryRun();
});
}
}</code>
使用示例：
const q = new TaskQueue(2);
q.add(() => delay(1000).then(() => console.log('A')));
q.add(() => delay(1000).then(() => console.log('B')));
q.add(() => delay(1000).then(() => console.log('C'))); // A/B 并发，C 等待
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
