C#动态创建Task并等待完成问题求助

我来帮你搞定这个分批执行Task的问题！你遇到的“i=10时未等待、最后也未等待”的情况，大概率是代码里的分批逻辑有漏洞，或者没处理好循环变量的闭包问题。下面给你详细的解决思路和可直接用的代码示例：

先分析可能的问题根源 #

你原来的代码可能踩了这几个坑：

• 闭包变量捕获错误：如果在Task里直接用循环变量（比如i或j），所有Task会共享同一个变量引用，导致实际执行时拿到的是循环结束后的最终值，看起来像是没按顺序执行；
• 分批等待逻辑错误：没有把每一批的Task单独收集起来等待，而是把所有Task堆到一个集合里最后才等，或者循环里没触发等待就直接创建下一批；
• 最后一批处理遗漏：当总数量不是batchSize的整数倍时，最后一批不足10个的Task没被正确等待。

解决方案1：同步阻塞式分批等待（适合控制台等同步场景） #

这种方式用Task.WaitAll阻塞当前线程，等待每一批Task全部完成后再执行下一批，逻辑清晰直观：

int totalImages = 50;
int batchSize = 10;

for (int i = 0; i < totalImages; i += batchSize)
{
    // 计算当前批次的结束位置，避免最后一批越界
    int endIndex = Math.Min(i + batchSize, totalImages);
    List<Task> currentBatchTasks = new List<Task>();

    for (int j = i; j < endIndex; j++)
    {
        // 重点：必须把循环变量j赋值给局部变量，避免闭包陷阱！
        int imageIndex = j;
        currentBatchTasks.Add(Task.Run(() =>
        {
            // 替换成你的图片处理逻辑，比如打开、处理图片
            Console.WriteLine($"正在处理第 {imageIndex + 1} 张图片");
            // 模拟操作耗时（实际代码替换成你的业务逻辑）
            System.Threading.Thread.Sleep(100);
        }));
    }

    // 等待当前批次所有Task执行完成
    Task.WaitAll(currentBatchTasks.ToArray());
    Console.WriteLine($"第 {i / batchSize + 1} 批处理完成");
}

Console.WriteLine("所有图片处理完毕！");

解决方案2：异步非阻塞式分批等待（推荐，适合UI或异步场景） #

如果是在UI项目或者追求非阻塞体验，用Task.WhenAll结合异步方法，不会阻塞主线程：

async Task ProcessImagesInBatchesAsync()
{
    int totalImages = 50;
    int batchSize = 10;

    for (int i = 0; i < totalImages; i += batchSize)
    {
        int endIndex = Math.Min(i + batchSize, totalImages);
        List<Task> currentBatchTasks = new List<Task>();

        for (int j = i; j < endIndex; j++)
        {
            int imageIndex = j;
            currentBatchTasks.Add(Task.Run(async () =>
            {
                Console.WriteLine($"正在处理第 {imageIndex + 1} 张图片");
                // 这里用异步IO操作更高效，比如异步读取图片文件
                // await File.ReadAllBytesAsync($"image_{imageIndex}.png");
                await Task.Delay(100); // 模拟异步耗时
            }));
        }

        // 异步等待当前批次完成，不会阻塞线程
        await Task.WhenAll(currentBatchTasks);
        Console.WriteLine($"第 {i / batchSize + 1} 批处理完成");
    }

    Console.WriteLine("所有图片处理完毕！");
}

// 调用异步方法（注意在异步上下文里调用，比如UI的按钮点击事件）
// await ProcessImagesInBatchesAsync();

额外注意事项 #

1. 异常处理：如果图片处理可能抛出异常，记得在Task内部加try-catch，或者在WaitAll/WhenAll之后处理AggregateException；
2. IO密集型优化：如果是打开图片这类IO操作，优先用异步IO方法（比如Image.FromStreamAsync、File.ReadAllBytesAsync），不要用Task.Run包裹同步IO，这样能更高效利用线程池；
3. 批次大小调整：如果是CPU密集型的图片处理，批次大小建议不要超过CPU核心数，避免过多线程上下文切换消耗性能。

内容的提问来源于stack exchange，提问作者Schlodi