线程安全的内部线程工作者

Question

我想知道如何在执行线程内部做到线程安全，让我通过示例解释一下：

假设我想要一个命令管道，这些命令应该一个接一个地连续执行，但在我的线程中我等不及了他们。线程通常处于睡眠状态，如果某个命令入队，则线程被唤醒，然后执行队列中的所有命令，并再次进入睡眠模式，直到新命令入队。比如：

public void Enqueue(ICommand command)
{
    this.queue.Enqueue(command);
    this.synchroHandler.Set();
}

private void Pipeline()
{
    while (true)
    {
        this.synchroHandler.WaitOne();

        while (this.queue.Count > 0)
        {
            ICommand command = this.queue.Dequeue();
            command.Execute();
        }
        // what if command will be enqueued between previous command - HERE

        // ... and this command HERE
        this.synchroHandler.Reset();
    }
}

public void Main()
{
    this.queue = new ThreadSafeQueue<ICommand>();
    this.computionHandler = new ManualResetEvent(false);
    Thread thread = new Thread(new ThreadStart(this.Pipeline));
    thread.Start();

    // start adding commands to pipeline
    this.Enqueue(command1);
    this.Enqueue(command2);
    ...
}

假设我的队列实现是线程安全的，所以 this.queue.Count、this.queue.Enqueue 和 this.queue.Dequeue 使用相同的锁。示例中显示的 Ss 是否将在“}”和 this.synchroHandler.Reset() 之间调用 public Enqueue()；即使队列中有一项，线程也会最终休眠（this.synchroHandler.Set() 将在 this.synchroHandler.Reset() 之前调用）。知道如何使这个模式线程安全吗？

Answer 1

查看 BlockingCollection， System.Collections.Concurrent 中的线程安全生产者-消费者命名空间。

Answer 2

您应该在 WaitOne() 之后立即调用 this.synchroHandler.Reset()。

因此，如果在Reset之前调用Queue，您将进入while循环，如果在检查queue.Count之后调用Queue，则下次调用WaitOne()时，它将立即返回并进入while循环。

Answer 3

你能把它改成旋转吗？因此，每隔 10 毫秒，线程就会醒来并检查队列是否有项目，否则会再次进入睡眠状态。

while (true)
    {
        while (this.queue.Count > 0)
        {
            ICommand command = this.queue.Dequeue();
            command.Execute();
        }
        Thread.Sleep(10);
    }