急切地处理 ManualResetEvent

Question

我有一个类允许其他线程等待，直到它使用ManualResetEventSlim 完成操作。 （操作通常很简短）

这个类没有明确的生命周期，所以没有一个地方可以让我轻松关闭事件。
相反，我想在事件完成后立即关闭它——一旦它发出信号，并且在任何等待线程唤醒之后。

出于性能原因，我不想使用锁。

这段代码是线程安全的吗？可以做得更快吗？

volatile bool isCompleted;
volatile int waitingCount;
ManualResetEventSlim waiter = new ManualResetEventSlim();

//This method is called on any thread other than the one that calls OnCompleted
public void WaitForCompletion() {
    if (isCompleted)
        return;

    Interlocked.Increment(ref waitingCount);
    Thread.MemoryBarrier();
    if (!isCompleted)
        waiter.Wait();

    if (0 == Interlocked.Decrement(ref waitingCount)) {
        waiter.Dispose();
        waiter = null;
    }
    return;
}

//This method is called exactly once.
protected internal virtual void OnCompleted(string result) {
    Result = result;
    isCompleted = true;
    Thread.MemoryBarrier();
    if (waitingCount == 0) {
        waiter.Dispose();
        waiter = null;
    } else
        waiter.Set();
}

Answer 1

我在您的代码中看到的最重要的事情是在调用Dispose 之后将waiter 设置为null。我在我负责的非托管接口上有大量托管包装器，当我迁移到 .Net 4.0 时，这种做法又在某些线程场景中对我产生了影响。

ManualResetEventSlim.Dispose 上的 MSDN 信息表明它不是线程安全的，但是，查看其实际实现，从多个线程多次调用 Dispose 并没有什么危险。此外，IDisposable 的实现应该非常容忍多次调用（如其设计指南中所述）。

我曾尝试过的一个想法是对OnCompleted 稍微重新排序，以便读者在完成后不久订阅：

//This method is called exactly once.
protected internal virtual void OnCompleted(string result) {
    Result = result;
    isCompleted = true;

    waiter.Set();
    Thread.MemoryBarrier();
    if (waitingCount == 0) {
        waiter.Dispose();
    }
}

Answer 2

更糟糕的是，在某些情况下它根本不会处理服务员。如果您在waitingCount > 0 时调用OnCompleted，isCompleted 标志将设置为true，但不会处理服务员。当有东西调用WaitForCompletion时，它会看到isCompleted是true，并立即退出。 waiter.Dispose 永远不会被调用。

为什么不使用类似SpinLock 的东西，它使用与ManualResetEventSlim 相同的逻辑？如果您的等待时间通常很短，那么锁可能不会被争用，这是一个巨大的胜利。如果等待时间很长，那么ManualResetEventSlim 无论如何都要为内核转换付出代价。

您确定使用锁会非常昂贵吗？有“知道”，然后有测量。 . .