c# - ConcurrentQueue 一个元素被两个线程取走

Question

我希望两个线程与一个队列一起工作。第一个线程应该每 2 秒调用一次，第二个线程 - 每 3 秒调用一次。两个线程应同时启动。访问队列的第一个元素时出现问题。两个线程都获取索引为 0 的元素。有时它会发生在队列的其他元素上，而不仅仅是第一个元素。我在控制台上有这样的输出:

• 项目 0 由 1 处理时间:3:27:8
• 项目 0 由 2 处理时间:3:27:8
• 项目 2 由 1 处理时间:3:27:10
• 项目 3 由 2 处理时间:3:27:11
• 项目 4 由 1 处理时间:3:27:12

等等..

这是我使用的代码:

    ConcurrentQueue<int> sharedQueue = new ConcurrentQueue<int>();

    for (int i = 0; i < 10; i++)
    {
        sharedQueue.Enqueue(i);
    }


    int itemCount= 0;


    Task[] tasks = new Task[2];
    for (int i = 0; i < tasks.Length; i++)
    {
        // create the new task
        tasks[i] = new Task(() =>
        {
            while (sharedQueue.Count > 0)
            {
                // define a variable for the dequeue requests
                int queueElement;
                // take an item from the queue
                bool gotElement = sharedQueue.TryDequeue(out queueElement);
                // increment the count of items processed
                if (gotElement)
                {
                    DateTime dt = DateTime.Now;
                    Console.WriteLine("Item " + itemCount + "processed by " 
                        + Task.CurrentId + " Time: " + dt.Hour + ":" + dt.Minute + ":" + dt.Second);
                    Interlocked.Increment(ref itemCount);   
               if (Task.CurrentId == 1) 
                    Thread.Sleep(2000);
                else 
                    Thread.Sleep(3000);                       
                }

            }
        });
        // start the new task
        tasks[i].Start();


    }
    // wait for the tasks to complete
    Task.WaitAll(tasks);
    // report on the number of items processed
    Console.WriteLine("Items processed: {0}", itemCount);
    // wait for input before exiting
    Console.WriteLine("Press enter to finish");
    Console.ReadLine();
}

Answer 1

替换以下行:

Console.WriteLine("Item " + itemCount + "processed by " ...);

用这一行:

Console.WriteLine("Item " + queueElement + "processed by " ...);

您看到的问题可能是由于任务几乎同时执行 Console.WriteLine 并且两者都看到相同的 itemCount 值，因为它们交错以 Interlocked.Increment 调用尚未发生的方式。打印出 queueElement 可能更有意义，因为它更有意义。