显式实现 IAsyncResult

Question

我通常对部分实现接口持谨慎态度。但是，IAsyncResult 有点特殊，因为它支持几种完全不同的使用模式。您多久使用一次/看到使用AsyncState/AsyncCallback 模式，而不是仅仅调用EndInvoke、使用AsyncWaitHandle 或轮询IsCompleted（讨厌）？

相关问题：Detecting that a ThreadPool WorkItem has completed/waiting for completion。

考虑这个类（非常近似，需要锁定）：

public class Concurrent<T> {
    private ManualResetEvent _resetEvent;
    private T _result;

    public Concurrent(Func<T> f) {
        ThreadPool.QueueUserWorkItem(_ => {
                                         _result = f();
                                         IsCompleted = true;
                                         if (_resetEvent != null)
                                             _resetEvent.Set();
                                     });
    }

    public WaitHandle WaitHandle {
        get {
            if (_resetEvent == null)
                _resetEvent = new ManualResetEvent(IsCompleted);
            return _resetEvent;
        }

    public bool IsCompleted {get; private set;}
    ...

它有WaitHandle（延迟创建，正如IAsyncResult 文档中所述）和IsCompleted，但我看不到AsyncState（{return null;}?）的合理实现。那么它实现IAsyncResult有意义吗？请注意，Parallel Extensions 库中的Task 确实实现了IAsyncResult，但只有IsCompleted 是隐式实现的。

Answer 1

您似乎有几个问题。让我们单独处理它们

懒惰地创建 WaitHandle

是的，这是最正确的方法。您应该以线程安全的方式执行此操作，但懒惰是一种方式。

不过，诀窍是处理 WaitHandle。 WaitHandle 是 IDisposable 的基础，必须及时处理。 IAsycResult 的文档不包括这种情况。最好的方法是在 EndInvoke 中。 BeginInvoke 的文档明确指出，对于每个 BeginInvoke，都必须有一个对应的 EndInvoke（或 BeginRead/EndRead）。这是处理 WaitHandle 的最佳位置。

AsyncState 应该如何实现？

如果您查看返回 IAsyncResult 的标准 BCL API，它们中的大多数都采用状态参数。这通常是从 AsyncState 返回的值（有关示例，请参见 Socket API）。对于任何返回 IAsyncResult 的 API BeginInvoke 样式 API，最好包含一个类型为对象的状态变量。没有必要，但很好的做法。

在没有状态变量的情况下，返回 null 是可以接受的。

IsCompleted API

这将高度依赖于创建 IAsyncResult 的实现。但是，是的，您应该实施它。

Answer 2

• 根据我的经验，只调用 EndInvoke 而不等待或先被回调很少有用
• 仅提供回调有时是不够的，因为您的客户可能希望同时等待多个操作（WaitAny、WaitAll）
• 我从来没有对 IsCompleted 进行过轮询，确实很糟糕！因此，您可以保存 IsCompleted 的实现，但它非常简单，似乎不值得让您的客户感到惊讶。

因此，异步可调用方法的合理实现应该真正提供完全实现的 IAsyncResult。

顺便说一句，您通常不需要自己实现 IAsyncResult，只需返回 Delegate.BeginInvoke 返回的内容即可。示例见 System.IO.Stream.BeginRead 的实现。