似乎 ConcurrentBag 不是线程安全的

Question

我编写了一个程序，列表生成器方法返回 IEnumerable 字符串，包括大量字符串（100 万个项目），并将其存储在 List of string 中，然后将 StringBuilder 实例中的所有项目附加到 Parallel.Foreach。然后我打印了 stringBuilderInstance.Length 。

问题是它少于 1000000 。 在googling 之后，我意识到 List 集合不是线程安全的，这导致了这个问题。 所以我想到了 2 个解决方案：

1) 使用锁定

2) 使用 ConcurrentBag

当我使用 lock 时，没问题，长度是 1 百万，但是：

当我使用字符串的 ConcurrentBag 时，长度比我预期的要短！

这个问题的根本原因是什么？

List-Creator 方法：

public static List<string> CreateList()
{
    List<string> result = new List<string>();
    for (int i = 0; i < 1000000; i++)
    {
        result.Add(1.ToString());
    }
    return result;
}

使用并发包：

public static void DoWithParallel_ThreadSafe()
{
    ConcurrentBag<string> listOfString = new ConcurrentBag<string>(CreateList());
    StringBuilder a = new StringBuilder();
    Action<string> appender = (number) =>
    {
        a.Append(number);
    };
    Parallel.ForEach(listOfString, appender);
    Console.WriteLine($"The string builder lenght : {a.Length}");
}

使用锁：

public static void DoWithParallel_UnsafeThread_Lock()
{
    List<string> listOfString = CreateList();
    StringBuilder a = new StringBuilder();
    Action<string> appender = (number) =>
    {
        lock (listOfString)
        {
            a.Append(number);
        }
    };
    Parallel.ForEach(listOfString, appender);
    Console.WriteLine($"The string builder lenght : {a.Length}");
}

主要：

static void Main(string[] args)
{
    DoWithParallel_UnsafeThread_Lock();
    DoWithParallel_ThreadSafe();
    Console.ReadKey();
}

提前谢谢你。

Answer 1

StringBuilder 不能从多个线程中变异，因此当您尝试这样做时代码无法正常工作。请注意，锁定是没有意义的；只是不要首先创建多个线程来完成工作，因为无法从多个线程完成工作。由于您永远不会从多个线程访问 ConcurrentBag，因此使用它而不是 List 毫无意义。

Answer 2

StringBuilder 不是线程安全的，这就是为什么一些Append() 调用“丢失”的原因。所以你仍然需要锁，即使你的集合是线程安全的。

（另外，请参阅 Servy 的回答，了解为什么您根本不需要集合是线程安全的。）