C#中使用Parallel.ForEachAsync异步操作多线程的方法_Asp.net

1. 核心概念

parallel.foreachasync 是在 .net 6 中引入的方法。
它的核心作用是：对一组数据执行异步操作，并且同时控制并发数量（也就是同时跑多少个任务）。
它完美解决了两个痛点：

传统的 parallel.foreach 不支持 async/await（它是为阻塞式 cpu 任务设计的）。
直接用 task.whenall(tasks) 会一次性把所有任务扔出去，如果数据有 10 万条，会瞬间耗尽内存或网络端口。

2. 基本语法与关键参数

public static task foreachasync<tsource>(
    this ienumerable<tsource> source,
    paralleloptions paralleloptions,
    func<tsource, cancellationtoken, valuetask> body
)

关键参数说明：

source：数据源（如数组、list、或你用 chunk() 切分出的块）。
paralleloptions：并行配置项，极其重要，包含两个核心属性：
- maxdegreeofparallelism：最大并发数。比如设为 5，表示最多同时运行 5 个异步任务，完成一个再补一个。
- cancellationtoken：取消令牌，用于中途终止所有并发任务。
body：要执行的异步逻辑（注意返回类型是 valuetask，不是 task，性能更好）。

3. 经典示例

示例 1：批量并发下载网页/api请求（最常见场景）

假设我们要下载 100 个网页，如果串行可能需要 1 分钟，但如果同时开 10 个并发，只需 6 秒。

using system.net.http;
list<string> urls = geturls(); // 假设有 100 个 url
using httpclient client = new httpclient();
// 配置并行选项：最大并发 10
var options = new paralleloptions { maxdegreeofparallelism = 10 };
console.writeline("开始并发下载...");
await parallel.foreachasync(urls, options, async (url, ct) =>
{
    try
    {
        // 传入 ct，如果外部取消，当前请求会立即中止
        string content = await client.getstringasync(url, ct);
        console.writeline($"成功下载 {url}，长度: {content.length}");
    }
    catch (operationcanceledexception)
    {
        // 被取消
    }
    catch (exception ex)
    {
        console.writeline($"下载失败 {url}: {ex.message}");
    }
});
console.writeline("全部下载完成。");

示例二：收集结果

foreachasync 本身没有返回值（返回 task），如果需要收集处理结果，必须使用线程安全集合（如 concurrentbag 或 concurrentqueue）。**

using system.collections.concurrent;
using system.diagnostics;

public static async task example_withresultcollection()
{
    var inputs = enumerable.range(1, 10);
    var results = new concurrentbag<int>(); // 线程安全集合

    await parallel.foreachasync(inputs, async i =>
    {
        await task.delay(100); // 模拟耗时操作
        int result = i * i;    // 计算逻辑
        results.add(result);   // 并发添加结果（线程安全）
        
        console.writeline($"{datetime.now:mm:ss:fff} - 处理 {i}");
    });

    console.writeline($"结果数量: {results.count}");
}

示例三：配合取消令牌

在用户关闭窗口或点击“停止”按钮时优雅地停止处理。

public static async task example_withcancellation(cancellationtoken cts)
{
    var range = enumerable.range(0, 1000);
    
    try
    {
        await parallel.foreachasync(range, 
            new paralleloptions { cancellationtoken = cts, maxdegreeofparallelism = 10 }, 
            async (i, ct) =>
            {
                // 如果外部取消，这里会抛出 operationcanceledexception
                await task.delay(100, ct); 
                console.writeline($"处理中: {i}");
            });
    }
    catch (operationcanceledexception)
    {
        console.writeline("任务被用户取消。");
    }
}

4. 核心优势对比表

特性	foreach + await	task.whenall	parallel.foreachasync
执行方式	串行（一个接一个）	全量并发（同时启动所有）	可控并发（池化执行）
内存/资源占用	极低	极高（容易内存溢出/端口耗尽）	适中（按需启动）
总耗时	最长	最短（如果不崩溃的话）	较短（与并发数成正比）
支持取消	支持	支持	完美支持

5. 注意事项与避坑指南

必须限制并发数：
不设置 maxdegreeofparallelism 时，默认可能会使用处理器数量作为并发度。对于网络请求，建议显式设置为 5 到 20 之间（根据目标服务器的承受能力和你的网络带宽决定），防止把对方服务器打挂，或触发对方防爬机制被封 ip。

线程安全问题（最容易踩的坑）：
在并发环境下，parallel.foreachasync 的内部相当于多线程同时运行。如果你在里面修改了 ui 绑定的集合（如 observablecollection）或普通的计数字典，极大概率会报错或数据错乱。

集合操作：使用 concurrentdictionary 或 concurrentbag，或者用 lock。
ui 更新：如果要在里面更新 wpf/winforms 的 ui，需要使用 dispatcher.invoke。

异常处理：

如果在循环体内抛出异常（且未 catch 吞掉），parallel.foreachasync 会将异常包装进 aggregateexception 抛出。
如果你想让某个任务失败不影响其他任务，就在循环体内部 try-catch 吞掉单次异常。
如果收到 cancellationtoken，必须立即停止并抛出 operationcanceledexception。

以上就是c#中使用parallel.foreachasync异步操作多线程的方法的详细内容，更多关于c# parallel.foreachasync多线程异步操作的资料请关注代码网其它相关文章！