Parallel.Invoke 是 .NET 中一次性并行执行多个无返回值、无依赖关系 Action 委托的方法,适用于日志写入、缓存刷新等彼此独立的任务;不适用于需返回值、顺序控制或并发限制的场景。

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 极可能都输出 0(取决于调度时机),但 C 修改了 i,而 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、支持返回值、天然集成取消逻辑
简单并行调用,Parallel.Invoke 足够;一旦需求变复杂(比如要等全部完成再做下一步、要限制最多跑 3 个、要记录每个结果),就该切到 Task.WhenAll 或 ParallelOptions 配合 Parallel.ForEach。
真正容易被忽略的是:它不保证执行顺序,也不保证 CPU 密集型任务一定更快——如果所有任务都在争抢同一块锁或磁盘 I/O,加并行反而更慢。










