.NET Core控制台应用多线程实现示例及最佳实践咨询

实现示例 #

1. 使用Parallel.ForEach（同步并行） #

如果业务逻辑是同步执行的，Parallel.ForEach是最直接的实现方式，它会自动利用线程池调度任务：

public void ProcessDataParallel(List<Data> dataList)
{
    Parallel.ForEach(dataList, data =>
    {
        // 执行你的业务逻辑，务必注意线程安全
        // business logic...
    });
}

如果需要限制并行度（避免过度占用资源），可以通过ParallelOptions配置：

public void ProcessDataParallel(List<Data> dataList)
{
    var options = new ParallelOptions 
    { 
        MaxDegreeOfParallelism = Environment.ProcessorCount * 2 
    };
    Parallel.ForEach(dataList, options, data =>
    {
        // business logic...
    });
}

2. 使用Task.WhenAll（异步并行） #

如果业务逻辑本身包含IO操作（比如数据库查询、文件读写），更推荐用异步并行方案，避免阻塞线程池：

public async Task ProcessDataAsync(List<Data> dataList)
{
    var tasks = dataList.Select(data => ProcessSingleDataAsync(data));
    await Task.WhenAll(tasks);
}

// 拆分单独的异步处理方法，便于维护和异常隔离
private async Task ProcessSingleDataAsync(Data data)
{
    // 异步业务逻辑示例
    // await DbContext.SaveChangesAsync();
    // await File.WriteAllTextAsync($"data_{data.Id}.txt", data.Content);
}

最佳实践与潜在问题 #

• 线程安全优先：如果业务逻辑涉及共享资源（静态变量、全局集合、数据库连接池等），必须通过lock语句、并发集合（ConcurrentBag/ConcurrentDictionary）或其他线程安全机制保护，否则会出现数据竞争、脏读脏写等问题。
• 适配任务类型调整并行度：
  • CPU密集型任务：并行度建议设为Environment.ProcessorCount左右，超过CPU核心数会增加上下文切换开销，反而降低性能。
  • IO密集型任务：可适当提高并行度，但要考虑外部资源限制（比如数据库连接池上限、API请求频率限制）。
• 异常处理要全面：
  • Parallel.ForEach抛出的异常会被包装为AggregateException，需要遍历InnerExceptions逐个处理。
  • Task.WhenAll默认会抛出第一个失败的任务异常，若要捕获所有异常，需先等待所有任务完成，再遍历任务状态检查。
• 避免阻塞异步代码：控制台应用中调用异步方法时，不要直接用Task.Wait()或Task.Result（容易引发死锁），推荐使用.NET 6+的顶级语句直接await，或用GetAwaiter().GetResult()替代。
• 及时释放资源：每个任务中使用的资源（文件流、数据库连接、网络请求）要通过using语句确保及时释放，避免资源泄漏。
• 测试验证性能收益：不要默认多线程一定能提升性能，对于小数据量场景，单线程的开销反而更小；务必通过基准测试（比如BenchmarkDotNet）验证优化效果。

内容的提问来源于stack exchange，提问作者Alexandre Cordeiro Trapp