6

我通常对部分实现接口持谨慎态度。然而，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吗？请注意，Task在 Parallel Extensions 库中确实实现了IAsyncResult，但只是IsCompleted隐式实现。

4

2 回答 2

3

看来您有几个问题。让我们单独处理它们

懒惰地创建 WaitHandle

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

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

AsyncState 应该如何实现？

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

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

已完成 API

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

于 2009-01-02T02:02:36.680 回答
2
  • 以我的经验，只调用 EndInvoke 而不等待或先被回调很少有用
  • 仅提供回调有时是不够的，因为您的客户可能希望一次等待多个操作（WaitAny、WaitAll）
  • 我从来没有投票过 IsCompleted，确实很糟糕！因此，您可以保存 IsCompleted 的实现，但它非常简单，似乎不值得让您的客户感到惊讶。

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

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

于 2009-01-02T00:04:50.910 回答