JS如何实现请求队列

RequestQueue

class RequestQueue {
    constructor(concurrency = 3) {
        this.concurrency = concurrency; // 最大并发数
        this.queue = []; // 等待执行的任务队列
        this.running = 0; // 当前正在运行的任务数
        this.isProcessing = false; // 队列是否正在处理中，用于防止重复启动处理器
    }

    /**
     * 添加一个任务到队列。任务是一个返回Promise的函数。
     * @param {Function} taskFn - 一个返回Promise的函数
     * @returns {Promise} - 返回任务执行的Promise
     */
    addTask(taskFn) {
        return new Promise((resolve, reject) => {
            this.queue.push({ taskFn, resolve, reject });
            this.processQueue(); // 每次添加任务都尝试处理队列
        });
    }

    async processQueue() {
        // 如果正在运行的任务数已达到并发上限，或者队列中没有待处理任务，则停止
        if (this.running >= this.concurrency || this.queue.length === 0) {
            return;
        }

        const { taskFn, resolve, reject } = this.queue.shift(); // 取出队列头部任务
        this.running++; // 增加正在运行的任务计数

        try {
            const result = await taskFn(); // 执行任务
            resolve(result); // 任务成功，解决对应的Promise
        } catch (error) {
            console.error('任务执行失败:', error);
            reject(error); // 任务失败，拒绝对应的Promise
        } finally {
            this.running--; // 任务完成（无论成功失败），减少正在运行的任务计数
            this.processQueue(); // 任务完成后，再次尝试处理队列，以启动下一个任务
        }