使用事件处理程序中的yield

Question

我有一个方法 Foo.LongRunningMethod()，它执行一些非常复杂的处理，可能会持续很长时间。在此过程中，只要遇到特定条件，它就会触发 Foo.InterestingEvent。我希望能够公开这些事件的枚举，并且希望能够在 LongRunningMethod 实际完成之前开始迭代。换句话说，我想要的是这样的：

public IEnumerable<InterestingObject> GetInterestingObjects()
{
    foo.InterestingEvent += (obj) => { yield return obj; }
    foo.LongRunningMethod();

    yield break;
}

不过，这不起作用，因为你不能从匿名方法中产生返回（并且因为使用 的方法>yield 不能返回 void，而我们的事件处理程序会这样做）。还有另一种习惯用法可以让我完成这个任务吗？或者这只是一个坏主意？

Answer 1

您希望能够订阅来自 LongRunningMethod 的事件流，并在事件发生时从 IEnumerable 生成另一个值？您可能会发现 .NET 反应式扩展很有用：http://msdn.microsoft。 com/en-us/devlabs/ee794896.aspx

反应式扩展为您提供了 IObservable，它实际上是一个仅推送的 IEnumerable。您可以围绕事件（例如您的InterestingEvent）创建一个IObservable包装器，并从那里对其进行可枚举样式的处理（例如生成对象流）。

编辑：“除了采用 Microsoft 的新库之外，还有什么方法可以让我完成此任务吗？”您正在做的是将推送序列（事件的发生）转换为拉动序列（调用 IEnumerable）。

拉取和推送可能不会协调，因此您需要在某个地方缓冲拉取之前推送的新值。最直接的方法可能是采用生产者-消费者安排：将它们推送到由 GetInterestingObjects 的调用方使用的 List 中。

根据事件的引发方式，您可能需要将生产者和使用者放在不同的线程上。 （当您要求反应式扩展在 IObservable 和 IEnumerable 之间进行转换时，所有这些都是反应式扩展最终要做的事情。）

Answer 2

我会在与主线程通信的单独线程中运行 LongRunningMethod()：事件处理程序将 InterestingObject 推送到某个同步队列中，并向主线程发出信号，当新的价值到来。

主线程等待队列中的对象并使用yield返回它们。

或者，您也可以在每次引发事件时阻塞子线程，直到主线程返回值并且 IEnumerable 的使用者请求下一个值。

Answer 3

蒂姆·罗宾逊的回答中的这句话让我思考：

您正在做的是将推序列（事件的发生）转换为拉序列（调用 IEnumerable）。

将推序列转换为拉序列很困难，这也是我的问题的根源。但相反（将拉序列变成推序列）是微不足道的，这种见解给了我解决方案。我将 LongRunningMethod 更改为内部可枚举版本，并进行了简单的重构，将每个事件回调替换为 yield return 并在末尾添加 yield break 。然后，我将现有的 LongRunningMethod 转换为一个包装器，它只为返回的所有内容触发事件：

internal IEnumerable<InterestingObject> FindInterestingObjects() 
{ 
    /* etc */ 
}

public void LongRunningMethod()
{
    foreach (var obj in FindInterestingObjects())
    {
        OnInterestingEvent(obj);
    }
}

这保留了公共接口，同时为我提供了一个简洁的枚举，我可以将其用于需要它的场景。作为一个重要的附带好处，如果我愿意的话，这也允许我尽早放弃长时间的计算，这对于基于事件或多线程的版本来说是很难做到的。