c# - ConcurrentQueue c#，不准确的结果？

Question

我想问一下c#中的queue如果 ConcurrentQueue 是安全线程，为什么这段代码的结果是 ~98 k？我有什么问题吗？

class Program
{
    static int sum = 0;
    static ConcurrentQueue<int> queue = new ConcurrentQueue<int>();

    static void Main()
    {
        for (int i = 0; i < 100000; i++)
        {
            queue.Enqueue(1);
        }

        Task t1 = Task.Run(() => Calculate());
        Task t2 = Task.Run(() => Calculate());

        Task.WaitAll(t1, t2);

        Console.WriteLine($"Sum = {sum}");
        Console.ReadKey();
    }

    static void Calculate()
    {

        int result;
        while (queue.TryDequeue(out result))
        {
            sum += result;
        }
    }
}

Answer 1

问题是:

sum += result;

那不是原子的。它是有效的:

var tmp = sum;
tmp += result;
sum = tmp;

如果你的两个线程同时到达中间线，你认为会发生什么？

您可以使用 Interlocked.Add 解决此问题:

while (queue.TryDequeue(out result))
{
    Interlocked.Add(ref sum, result);
}

请注意，这与使用 ConcurrentQueue 无关 - 如果您的循环只是:

for (int i = 0; i < 50000; i++)
{
    sum++; // Just as bad...
}