WaitHandle 在不应该关闭时关闭

Question

这段代码大部分时间都有效，所以我在考虑一些竞争条件。 Result 类是不可变的，但我认为问题不在于该类。

public Result GetResult()
{
    using (var waitHandle = new ManualResetEvent(false))
    {
        Result result = null;

        var completedHandler = new WorkCompletedEventHandler((o, e) =>
        {
            result = e.Result;

            // somehow waitHandle is closed, thus exception occurs here
            waitHandle.Set();
        });
        try
        {
            this.worker.Completed += completedHandler;

            // starts working on separate thread
            // when done, this.worker invokes its Completed event
            this.worker.RunWork();

            waitHandle.WaitOne();

            return new WorkResult(result);
        }
        finally
        {
            this.worker.Completed -= completedHandler;
        }
    }
}

编辑：抱歉，我在调用 GetResult() 方法之前错过了对 this.worker.RunWork() 的调用。这显然导致（有时）两次执行相同的工作，尽管我不确定为什么 waitHandle 在 waitHandle.Set() 之前关闭，尽管 Completed 事件触发了两次。这根本没有影响 IO 工作（结果是正确的；在我更改代码以手动关闭 waitHandle 之后）。

因此，Iridium's answer 应该是最接近的答案（如果不是正确的答案），即使问题不完整。

Answer 1

在您提供的代码中似乎没有什么特别的问题，这表明您未显示的代码中可能存在导致问题的东西。我假设您正在使用的worker 是您的代码库的一部分（而不是像BackgroundWorker 这样的.NET BCL 的一部分？）如果出现问题，可能值得发布代码这就是问题所在。

例如，如果同一个工作线程被多个线程重复使用（或者有一个错误，其中Completed 可以为同一个工作多次引发），那么如果工作线程使用“通常”意味着用于调用事件处理程序，即：

var handler = Completed;
if (handler != null)
{
    handler(...);
}

您可能有一个实例，其中var handler = Completed; 在finally 子句之前执行（因此在completedHandler 与Completed 事件分离之前），但handler(...)在退出using(...) 块之后调用（因此在ManualResetEvent 被释放之后）。您的事件处理程序将在 waitHandle 被释放后执行，并且您看到的异常将被抛出。

Answer 2

没有明显的原因导致发布的代码会失败。但是我们看不到堆栈跟踪，也看不到触发 Completed 事件的逻辑，因此几乎没有机会为您调试它。随意地，如果事件触发不止一次，那么您肯定会遇到这种种族问题。

棘手的线程问题很难调试，线程竞争是发生在微秒级的问题。尝试调试它就足以让比赛消失。或者这种情况很少发生，以至于有任何发现问题的希望都太少了，以至于无法证明尝试的合理性。

此类问题通常需要日志记录来诊断比赛。请务必选择轻量级的日志记录方法，日志记录本身可以改变足够的时间以防止比赛发生。

最后但同样重要的是：请注意，在这里使用线程是没有意义的。通过直接调用由 RunWork() 启动的任何线程执行的代码，您将获得完全相同相同的结果。减去开销和头痛。

Answer 3

如果您摆脱了使用您的代码将不会在您指定的行抛出异常... 如果你真的需要，你必须找到一个合适的地方来处理它。

public Result GetResult()
{
    var waitHandle = new ManualResetEvent(false);

        Result result = null;

        var completedHandler = new WorkCompletedEventHandler((o, e) =>
        {
            result = e.Result;

            // somehow waitHandle is closed, thus exception occurs here
            waitHandle.Set();
            waitHandle.Dispose();
        });
        try
        {
            this.worker.Completed += completedHandler;

            // starts working on separate thread
            // when done, this.worker invokes its Completed event
            this.worker.RunWork();

            waitHandle.WaitOne();

            return new WorkResult(result);
        }
        finally
        {
            this.worker.Completed -= completedHandler;
        }
}