为何Dasync/AsyncEnumerable的ParallelForEachAsync方法始终不返回？

看起来你遇到的棘手问题是用Dasync/AsyncEnumerable的ParallelForEachAsync处理8个元素时，结果集合始终少一个。结合你的代码和描述，我梳理了几个可能的原因和对应的解决思路：

1. 先确认所有任务是否真的执行了 #

建议先在异步委托里加日志输出，把每个产品的处理过程打出来，看看是不是有某个元素根本没进入处理逻辑，或者处理后没执行Add操作：

async product =>
{
    Console.WriteLine($"开始处理产品：{product.MaterialNumber}"); // 新增日志
    OsmData osmData;
    try
    {
        osmData = await GetOsmData(_osmUrl.Replace("articlenumber", product.MaterialNumber.ToString())).ConfigureAwait(false);
    }
    catch (Exception e)
    {
        Console.WriteLine($"处理产品{product.MaterialNumber}出错：{e.Message}"); // 异常日志
        osmData = null;
    }
    // 原有逻辑不变
    product.OsmPrintImageAvailable = osmData != null && osmData.PrintingData.Count > 0;
    result.Add(product);
    Console.WriteLine($"已添加产品{product.MaterialNumber}，当前集合数量：{result.Count}"); // 记录添加后的计数
}

通过日志你能直观看到哪一步出了问题——是某个产品没被处理，还是处理后没成功添加。

2. 替换为.NET原生的并行异步实现（推荐） #

Dasync的ParallelForEachAsync可能存在边缘场景的bug（比如任务调度或异常处理的隐性问题），而.NET 6及以上版本已经内置了稳定的Parallel.ForEachAsync，而且原生实现的维护和兼容性更好。你可以直接替换，同时优化结果收集的方式：

private async Task<List<SampleProduct>> CheckOsmDataAsync(List<SampleProduct> products)
{
    var processedProducts = new List<SampleProduct>(products.Count);
    var syncLock = new object();

    await Parallel.ForEachAsync(products, new ParallelOptions
    {
        MaxDegreeOfParallelism = Environment.ProcessorCount // 对应你原代码的0，自动取处理器核心数
    }, async (product, ct) =>
    {
        OsmData osmData;
        try
        {
            osmData = await GetOsmData(_osmUrl.Replace("articlenumber", product.MaterialNumber.ToString())).ConfigureAwait(false);
        }
        catch (Exception e)
        {
            osmData = null;
        }

        product.OsmPrintImageAvailable = osmData != null && osmData.PrintingData.Count > 0;
        
        lock (syncLock) // 用锁保证List的线程安全，也可以继续用ConcurrentBag
        {
            processedProducts.Add(product);
        }
    });

    return processedProducts;
}

如果不需要严格控制并行度，用Task.WhenAll结合异步Select会更简洁，还不用手动管理线程安全集合：

private async Task<List<SampleProduct>> CheckOsmDataAsync(List<SampleProduct> products)
{
    var tasks = products.Select(async product =>
    {
        OsmData osmData;
        try
        {
            osmData = await GetOsmData(_osmUrl.Replace("articlenumber", product.MaterialNumber.ToString())).ConfigureAwait(false);
        }
        catch (Exception e)
        {
            osmData = null;
        }

        product.OsmPrintImageAvailable = osmData != null && osmData.PrintingData.Count > 0;
        return product;
    });

    return (await Task.WhenAll(tasks)).ToList();
}

这种方式Task.WhenAll会等待所有异步任务完成后统一收集结果，能从根源避免元素丢失的问题。

3. 给GetOsmData加超时机制 #

如果某个GetOsmData调用出现无限挂起（比如HTTP请求一直没响应且没设置超时），对应的异步委托就永远不会完成，导致ParallelForEachAsync一直等待，最终结果集合就会少这个元素。建议给请求加超时：

private async Task<OsmData> GetOsmData(string url)
{
    using var client = new HttpClient();
    client.Timeout = TimeSpan.FromSeconds(10); // 设置10秒超时
    // 原有请求逻辑...
}

这样能避免单个请求挂起导致整个批量任务卡住或结果缺失。

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