Method execute

packages/filesystem/limiter.ts:27–46

* 执行限速操作 * @param fn 要执行的操作函数 * @param op 操作类型，用于在遇到 429 时判断是否允许自动重试。默认值 "unknown" 不在白名单内，会被视为不可重试 * @returns 操作结果

(fn: () => Promise<T>, op = "unknown")

   * @returns 操作结果
   */
  async execute<T>(fn: () => Promise<T>, op = "unknown"): Promise<T> {
    // 如果当前运行的操作数已达到上限，则等待
    while (this.running >= this.maxConcurrent) {
      await new Promise<void>((resolve) => {
        this.queue.push(resolve);
      });
    }

    this.running++;
    try {
      return await this.executeWithRetry(fn, op);
    } finally {
      this.running--;
      // 执行完成后，从队列中取出下一个等待的操作
      const next = this.queue.shift();
      if (next) {
        next();
      }
    }
  }

  /**
   * 执行操作并处理 429 错误重试