c# Parallel.Invoke 的用法 c#如何并行执行多个方法

来源：这里教程网时间：2026-02-21 17:39:00 作者：

Parallel.Invoke 是什么，什么时候该用它

Parallel.Invoke

是 .NET 中用于**一次性并行执行多个无返回值、无依赖关系的 Action 委托**的便捷方法。它适合“几个独立任务，谁先做完谁先走”的场景，比如同时写日志、刷新缓存、发送通知——彼此不传参、不等结果、也不共享可变状态。

它不是万能替代

Task.Run

或

Parallel.ForEach

的方案。如果任务需要返回值、有执行顺序要求、或要控制并发数，

Parallel.Invoke

反而会掩盖问题。

基本用法和参数传递陷阱

直接传入多个

Action

即可，但要注意闭包捕获变量的问题：

int i = 0;
Parallel.Invoke(
    () => Console.WriteLine($"Task A: {i}"),
    () => Console.WriteLine($"Task B: {i}"),
    () => { i = 42; Console.WriteLine("Task C done"); }
);

上面代码中，A 和 B 极可能都输出

（取决于调度时机），但 C 修改了

，而 A/B 并不感知——这不是线程安全问题，而是典型的**变量捕获时机错误**。

正确做法是为每个委托提供独立副本：

用
let
式局部变量（C# 7+）：
var localI = i; () => Console.WriteLine(localI);
避免在 lambda 外部修改被闭包捕获的变量 若需共享状态，改用
ConcurrentDictionary
、
Interlocked
等线程安全类型

异常处理：一个失败，全部中断

Parallel.Invoke

内部使用

AggregateException

包装所有子任务异常。只要任一委托抛出异常，其余正在运行的任务会被取消（尽力而为），且最终只抛出一个

AggregateException

。

这意味着：

不能靠 try/catch 单个 lambda 来隔离错误 必须在外层 catch
AggregateException
，再遍历
.InnerExceptions
处理 若某个任务耗时很长且已出错，其他短任务也会被强行终止——这不是“超时控制”，而是“故障传播”

try
{
    Parallel.Invoke(
        () => { throw new InvalidOperationException("First fail"); },
        () => Thread.Sleep(2000) // 这个会被中断
    );
}
catch (AggregateException ae)
{
    foreach (var ex in ae.InnerExceptions)
    {
        Console.WriteLine(ex.Message);
    }
}

性能与替代方案对比

Parallel.Invoke

底层复用

ThreadPool

，启动开销小，但缺乏细粒度控制：

无法设置最大并行度（
MaxDegreeOfParallelism
），默认由调度器决定不支持取消令牌（
CancellationToken
）直接传入——得手动在每个 Action 里检查比手写
Task.Run
+
Task.WhenAll
更简洁，但后者能统一 await、支持返回值、天然集成取消逻辑

简单并行调用，