超时结束后触发事件

Question

我必须等待事件被触发。我最初的解决方案是使用 AutoResetEvent 和 WaitOne()，但该事件总是在等待超时结束后触发。所以我又回到了下面的方法，但我仍然遇到同样的问题。超时结束后 2 或 3 秒，无论超时是多少，事件都会被触发。

_wait = true;
_delayedResponse = null;

var thread = new Thread(delegate
{
        while (_wait)
        {
           Thread.Sleep(500);
           if (_delayedResponse != null)
               return;
        }
});

thread.Start();
var received = thread.Join(_responseTimeout);
_wait = false;

if (!received)
    throw new TimeoutException(
        "Timeout for waiting for response reached.");

return _delayedResponse;

以下是事件处理程序代码：

private void OnResponseArrived(object sender, ResponseEventArgs args)
{
    _delayedResponse = args.VerificationResponse;
}

事件本身是由调用上述函数的另一个函数触发的。 基本上它看起来像这样：

var result = DoStuff(); // Library function that is responsible for the event 
if (result.Status == Status.Wait)
   Wait(); // Function above

有谁知道导致这个问题的原因以及我如何解决它？

编辑：不再相关。转发了OnResponseArrived事件，因为我没有及时找到其他解决方案。

Answer 1

Thread.Join 是一个阻塞调用 - 它会阻止您正在调用的线程执行任何其他工作。我的猜测是，您正在后台线程上等待事件，但是引发事件的代码与您发布的代码运行在同一线程上。

通过调用 thread.Join 你正在阻塞应该进行处理的线程。因此，您等待超时到期...然后无论您发布的代码采用哪种方法都会完成...然后您的处理实际上发生并引发 ResponseArrived 事件。

如果您发布其余的代码，这将很有用，但解决方案的要点是在后台线程中运行实际工作（无论代码引发 ResponseArrived 事件） - 并删除您发布的代码中的额外线程。

编辑以回应评论...

为了同步您的两段代码，您可以使用AutoResetEvent。不要使用 Thread.Sleep 和其他代码，而是尝试如下操作：

// create an un-signalled AutoResetEvent
AutoResetEvent _waitForResponse = new AutoResetEvent(false);

void YourNewWorkerMethod()
{
    _delayedResponse = null;
    var result = DoStuff();

    // this causes the current thread to wait for the AutoResetEvent to be signalled
    // ... the parameter is a timeout value in milliseconds
    if (!_waitForResponse.WaitOne(5000))
        throw new TimeOutException();

    return _delayedResponse;
}


private void OnResponseArrived(object sender, ResponseEventArgs args)
{
    _delayedResponse = args.VerificationResponse;
    _waitForResponse.Set();  // this signals the waiting thread to continue...
}

请注意，在使用完 AutoResetEvent 后，您需要将其释放。

Answer 2

好吧，您需要做的第一件事是确保 DoStuff 实际上在后台线程中工作。

如果这是正确的，按照您现在编写代码的方式，您不需要生成第二个线程，只需将其加入到下面一行，类似这样的事情就可以工作（作为测试）：

// handler needs to be attached before starting
library.ResponseReceived += OnResponseReceived;

// call the method
var result = library.DoStuff();

// poll and sleep, but 10 times max (5s)
int watchdog = 10;
while (_delayedResponse == null && watchdog-- > 0)
   Thread.Sleep(500);

// detach handler - always clean up after yourself
library.ResponseReceived -= OnResponseReceived;

Console.WriteLine(_delayedResponse != null);

如果这有效，如果您正在编写 WinForms 应用程序，那么您应该考虑在后台线程中完成整个工作，然后在完成时通知 UI。当然，如果您需要帮助，您需要提供更多详细信息。