/** * 并发控制(Concurrency Limiter) * * 信号量模式,限制同时进行的视觉 API 调用数量。 * 约 50 行,零外部依赖。 */ /** * 信号量(Semaphore):最大并发限制 */ export declare class ConcurrencyLimiter { private running; private readonly queue; private readonly maxConcurrent; constructor(maxConcurrent?: number); /** * 获取信号量许可(自动排队等待) */ acquire(): Promise; /** * 释放信号量许可(唤醒一个等待者) */ release(): void; /** * 在并发限制下执行异步函数 * * @param fn 需要执行的函数 * @returns fn 的返回值 */ execute(fn: () => Promise): Promise; /** 当前正在运行的任务数 */ get runningCount(): number; /** 队列中等待的任务数 */ get waitingCount(): number; } export declare function getGlobalLimiter(maxConcurrent?: number): ConcurrencyLimiter; //# sourceMappingURL=concurrency-limiter.d.ts.map