C#中的并发编程与.NET任务并行库的使用示例和常见问题

在现代软件开发中，多核处理器已经成为标准配置，这为开发者提供了利用多线程编程来提升应用程序性能的机会。然而，传统的同步编程模型在面对高并发场景时显得力不从心，容易导致死锁、竞争条件等问题。为了简化并发编程，并提高程序的可维护性和可扩展性，.NET Framework引入了任务并行库（TPL，Task Parallel Library）和并发集合类型，这些工具使得编写高性能的并行代码变得更加简单。

什么是并发集合？

并发集合是指那些设计上允许多个线程同时访问而不会引起数据不一致问题的数据结构。在.NET Framework中，System.Collections.Concurrent命名空间提供了多种并发集合类，如ConcurrentQueue<T>、ConcurrentStack<T>、ConcurrentDictionary<TKey, TValue>等，它们都是线程安全的，可以有效地支持多线程环境下的操作。

常见问题与解决策略

问题1：选择合适的并发集合

• 分析：不同的应用场景可能需要不同类型的并发集合。例如，如果需要一个可以从两端添加或移除元素的队列，则ConcurrentQueue<T>可能不是最佳选择。
• 解决方案：根据实际需求选择最合适的并发集合类型。对于简单的先进先出（FIFO）操作，ConcurrentQueue<T>是一个很好的选择；而对于键值对存储，应考虑使用ConcurrentDictionary<TKey, TValue>。

问题2：并发集合的迭代

• 分析：直接遍历并发集合可能会遇到迭代过程中集合被修改的问题。
• 解决方案：使用foreach循环遍历时，确保集合在遍历期间不会被其他线程修改，或者采用只读快照模式进行遍历。

示例代码

using System;
using System.Collections.Concurrent;
using System.Threading;

public class ConcurrentExample
{
    private static readonly ConcurrentDictionary<int, string> _dictionary = new ConcurrentDictionary<int, string>();

    public static void Main()
    {
        // 添加元素
        _dictionary.TryAdd(1, "Hello");
        _dictionary.TryAdd(2, "World");

        // 并发更新
        Thread thread = new Thread(() =>
        {
            _dictionary[1] = "Updated";
        });
        thread.Start();
        thread.Join();

        // 安全地读取
        if (_dictionary.TryGetValue(1, out string value))
        {
            Console.WriteLine(value); // 输出: Updated
        }
    }
}

任务并行库（TPL）

任务并行库是.NET Framework提供的用于简化并行编程的一个框架。它通过System.Threading.Tasks命名空间下的Task类和Task<T>类来实现异步操作，极大地提高了开发效率。

常见问题与解决策略

问题1：任务取消

• 分析：长时间运行的任务可能需要支持取消机制。
• 解决方案：使用CancellationToken来通知任务应该停止执行。

问题2：异常处理

• 分析：并行执行的任务中如果发生异常，默认情况下不会立即中断程序执行。
• 解决方案：通过Task.WaitAll或Task.WhenAll等待所有任务完成，并检查是否有异常发生。

示例代码

using System;
using System.Threading.Tasks;

public class TaskParallelExample
{
    public static void Main()
    {
        var tasks = new Task[]
        {
            Task.Run(() => Console.WriteLine("Task 1 started")),
            Task.Run(() => { throw new Exception("Task 2 failed"); }),
            Task.Run(() => Console.WriteLine("Task 3 started"))
        };

        try
        {
            Task.WaitAll(tasks);
        }
        catch (AggregateException ex)
        {
            foreach (var innerEx in ex.InnerExceptions)
            {
                Console.WriteLine($"Error: {innerEx.Message}");
            }
        }

        Console.WriteLine("All tasks completed.");
    }
}