.NET 消费者/生产者（队列）

Question

我是 .NET/Threads 的新手，我想知道是否有人可以帮助我完成这项练习。我需要替换注释，以便使其在不锁定线程的情况下工作：

private Queue<int> queue;

public void ConsumeFunc(){
    while (true){
        // 1
        while (/* 2 */){
        // 3
        }
        int element = queue.Dequeue();
        // 4
        Console.WriteLine("Consume element: " + element);
        Thread.Sleep(new Random((int)DateTime.Now.Ticks).Next(0, 2) * 1000);
    }
}

private void ProduceFunc(){
    while (true) {
        // 1
        queue.Enqueue(DateTime.Now.Millisecond);
        // 2
        // 3
        Thread.Sleep(new Random((int)DateTime.Now.Ticks).Next(0, 2) * 1000);
    }
}

我管理了此操作，但尚未完成

public void ConsumerFunc(){
    while (true){
        Monitor.PulseAll(queue);    // 1
        while (queue.Count == 0){   /* 2 */
            Monitor.Wait(queue);    // 3
        }
        int element = queue.Dequeue();
        lock (queue)    // 4
        Console.WriteLine("Consume element: " + element);
        Thread.Sleep(new Random((int)DateTime.Now.Ticks).Next(0, 2) * 1000);
    }
}


public void ProducerFunc(){
    while (true) {
        lock (queue)    // 1
        queue.Enqueue(DateTime.Now.Millisecond);
        Monitor.PulseAll(queue);    // 2
        // 3 ???
        Thread.Sleep(new Random((int)DateTime.Now.Ticks).Next(0, 3) * 1000);
    }
}

并给出以下错误： 从不同步的代码块调用对象同步方法， 上Monitor.PulseAll(queue);

Answer 1

与其自己努力实现同步，不如看看 BlockingCollection。它会为您处理所有同步，并且比您使用 Queue 类和 Monitor 创建的任何内容都表现得更好。

.NET 文档、Stack Overflow 以及其他地方都有很多示例。您可能会发现我的文章很有用：http://www.informit。 com/guides/content.aspx?g=dotnet&seqNum=821