• 异步请求池

    Type Parameters

    • T

    Parameters

    • limit: number

      最大并发请求数量

    • taskArr: T[]

      任务数组,包含所有需要执行的任务

    • interatorFn: ((item, arr) => void)

      迭代函数,每个让你无实际执行的异步操作

        • (item, arr): void
        • Parameters

          • item: T
          • arr: T[]

          Returns void

    Returns Promise<void[]>

    返回一个Promise数组

    Description

    该函数用于并行执行异步任务,通过限制并发数来控制任务执行的效率和资源占用

    Example

    async function main() {
    // 示例任务数组
    const tasks = Array.from({ length: 10 }, (_, i) => i);

    // 异步任务迭代函数
    const asyncTask = async (item: number, arr: number[]) => {
    console.log(`开始处理任务 ${item}`);
    await new Promise((resolve) => setTimeout(resolve, 1000)); // 模拟耗时操作
    console.log(`任务 ${item} 完成`);
    };

    // 调用 asyncPool 函数
    await asyncPool(3, tasks, asyncTask);
    }

    // 运行示例
    main().catch(console.error);

Generated using TypeDoc