如何在C#中通过Task并行调用反射执行的方法？

嘿，这个需求很常见，用Task Parallel Library（TPL）来改造你的代码实现并行执行其实挺直接的。我给你几种实用的方案，你可以根据自己的场景选择：

方案1：用Parallel.ForEach快速替换循环 #

这是最简洁的方式，直接把原来的foreach换成Parallel.ForEach，TPL会自动帮你管理线程池和并行度：

MyClass myClass = InitializeMyClass();
string[] methods = GetMethodsToRun();

// 提前缓存MethodInfo，避免每次循环重复反射查找，提升性能
var methodInfos = methods.Select(m => myClass.GetType().GetMethod(m))
                         .Where(m => m != null) // 过滤掉找不到的方法，避免空引用
                         .ToList();

Parallel.ForEach(methodInfos, methodInfo =>
{
    methodInfo.Invoke(myClass, null);
});

注意事项： #

• 确保MyClass的实例和被调用的方法是线程安全的！如果多个并行方法同时修改myClass的内部状态，很可能会引发竞态条件或者数据错乱。
• 可以通过ParallelOptions来控制并行度，比如限制最大并发数：

  var options = new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount };
  Parallel.ForEach(methodInfos, options, methodInfo => { ... });
  

方案2：用Task.WhenAll实现异步并行 #

如果你的代码是在异步上下文里（比如ASP.NET Core、WPF等），更推荐用异步方式的Task.WhenAll，这样不会阻塞线程池线程：

MyClass myClass = InitializeMyClass();
string[] methods = GetMethodsToRun();

var methodInfos = methods.Select(m => myClass.GetType().GetMethod(m))
                         .Where(m => m != null)
                         .ToList();

// 将每个方法调用包装成Task
var tasks = methodInfos.Select(methodInfo => Task.Run(() => 
{
    methodInfo.Invoke(myClass, null);
})).ToList();

// 等待所有任务完成
await Task.WhenAll(tasks);

异常处理提示： #

并行执行时如果多个方法抛出异常，这些异常会被包装成AggregateException。你可以这样捕获处理：

try
{
    Parallel.ForEach(methodInfos, methodInfo => { ... });
    // 或者 await Task.WhenAll(tasks);
}
catch (AggregateException ex)
{
    foreach (var innerEx in ex.InnerExceptions)
    {
        // 处理每个方法抛出的异常
        Console.WriteLine($"方法执行出错：{innerEx.Message}");
    }
}

额外优化建议 #

• 提前缓存MethodInfo：像上面代码里那样，先一次性把所有要调用的MethodInfo找出来，避免在循环里重复做反射操作，这能显著提升性能，尤其是当方法数量较多的时候。
• 过滤无效方法：一定要检查GetMethod返回的是否为null，避免空引用异常——如果GetMethodsToRun()返回了不存在的方法名，这一步能帮你避免崩溃。

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