AutoResetEvent过程？

Question

private ConcurrentQueue<Data> _queue = new ConcurrentQueue<Data>();
private AutoResetEvent _queueNotifier = new AutoResetEvent(false);

public void MoreData(Data example)
{
    _queue.Enqueue(example);
    _queueNotifier.Set();
}

private void _SimpleThreadWorker()
{
    while (_socket.Connected)
    {
        _queueNotifier.WaitOne();
        Data data;
        if (_queue.TryDequeue(out data))
        {
            //handle the data
        }
    }
}

一旦事件出队，我是否必须将其设置为 false，或者当事件返回 _queueNotifier.WaitOne() 时，它会自行返回 false 或者它是如何工作的？

我应该像下面的示例一样使用内部 while 还是两种方式都很好/相等？

while (_socket.Connected)
{
    _queueNotifier.WaitOne();
    while (!_queue.IsEmpty)
    {
        Data data;
        if (_queue.TryDequeue(out data))
        {
            //handle the data
        }
    }
}

Answer 1

如果您使用 .NET 4 中的 ConcurrentQueue，最好避免完全由 AutoResetEvent 自行处理。相反，创建一个 BlockingCollection 来包装ConcurrentQueue 并使用它 - 它可以完成您需要的一切。 （如果您只是使用无参数构造函数创建一个 BlockingCollection ，它无论如何都会为您创建一个 ConcurrentQueue 。）

编辑：如果您确实想仍然使用 AutoResetEvent，然后 WaitOne 将自动（并且原子地）重置事件 - 这是 AutoResetEvent 的“自动”部分。将此与 ManualResetEvent 进行比较，后者不会重置事件。

Answer 2

当您执行 _queueNotifier.Set() 时，事件将发出信号。当事件发出信号并且从另一个线程调用 _queueNotifier.WaitOne() 时，会同时发生两件事（即在内核模式下）：

• 事件变为未发出信号（因为它是自动重置）
• 调用的线程WaitOne 已解锁，

因此您不必自己显式设置事件状态。

然而，正如 Jon 所说，如果您对共享变量所做的唯一事情就是从队列中推送和拉出项目，那么简单地使用 BlockingCollection 会更方便。

如果您正在访问多个共享变量，那么围绕它使用单线程同步机制（您自己的）可能是有意义的。

另外，在我看来，如果您打算使用自己的代码，最好这样做：

public void MoreData(Data example)
{
    var queueWasEmpty = _queue.IsEmpty;
    _queue.Enqueue(example);
    if (queueWasEmpty) {
        _queueNotifier.Set();
    }
}

private void _SimpleThreadWorker()
{
    while (_socket.Connected)
    {
        _queueNotifier.WaitOne();
        Data data;
        while(!queue.IsEmpty) {
            if (_queue.TryDequeue(out data))
            {
                //handle the data
            }
        }
    }
}

这样，每当项目添加到当消费者功能繁忙时排队。您还可以避免在消费者函数的每次迭代中进入内核模式。

确实，对于后者，避免上下文切换是以添加 _queue.IsEmpty 测试为代价的（其中糟糕的实现无论如何都可能会进行上下文切换）；但是，该操作可能是作为互锁比较交换操作实现的，不需要进入内核模式。

免责声明：我没有检查源代码或IL来验证上述信息。