/** * Async - 异步工具函数 */ export interface ParallelLimitOptions { /** * 可选的停止检查函数 * 返回 true 时停止启动新任务 */ shouldStop?: () => boolean; } /** * 并发控制函数 - 滑动窗口模式 * 限制同时执行的异步任务数量 * * @param tasks 任务列表 * @param limit 最大并发数 * @param fn 任务执行函数 * @param options 选项 * @returns 所有任务的结果数组 * * @example * ```typescript * const results = await parallelLimit( * [1, 2, 3, 4, 5], * 2, * async (num) => num * 2, * { shouldStop: () => isCanceled } * ); * ``` */ export declare function parallelLimit(tasks: T[], limit: number, fn: (task: T) => Promise, options?: ParallelLimitOptions): Promise; /** * 延迟执行 * @param ms 延迟毫秒数 */ export declare function delay(ms: number): Promise; /** * 带重试的异步执行 * @param fn 要执行的异步函数 * @param maxRetries 最大重试次数 * @param retryDelay 重试间隔(毫秒) * @param shouldRetry 可选的重试条件判断函数 */ export declare function withRetry(fn: () => Promise, maxRetries?: number, retryDelay?: number, shouldRetry?: (error: Error, attempt: number) => boolean): Promise;