2

假设,我的IAsynchronous接口支持两种执行某些操作的方法(“开始/结束”模式):

  • IAsyncResult BeginOperation(AsyncCallback callback, object state)
  • EndOperation(IAsyncResult ar)

还假设我有课程A : IAsynchronousB : IAsynchronous. 我必须实现这个Compound : IAsynchronous类。'的Compound操作是调用A' 的操作,等待其完成,然后调用B' 的操作,然后像往常一样调用回调。

问题是如何设计Compound类:

  • 我应该保留原始对象并在' 操作完成state时调用原始回调。Compound因此,我不能简单地将它们传递给A.BeginOperationor B.BeginOperation
  • 此外,Compound.EndOperation应该重新抛出由A.EndOperationor抛出的任何异常B.EndOperation。如果A.EndOperation已引发异常,则Compound不应调用 ' 操作,B.EndOperation因为复合操作已失败。
  • 如果不仅有 2 个内部操作,而且有 3 个或更多,该怎么办?有没有通用的方法?

为了澄清,请考虑以下示例。假设我们有一个Multiplier支持以下方法的类:

  • IAsyncResult BeginMultiply(LargeNumber x, LargeNumber y, AsyncCallback callback, object state)
  • LargeNumber EndMultiply(IAsyncResult ar)

并且您要编写ThreeMultiplier支持以下方法的类:

  • IAsyncResult BeginMultiply(LargeNumber x, LargeNumber y, LargeNumber z, AsyncCallback callback, object state)
  • LargeNumber EndMultiply(IAsyncResult ar)

该类ThreeMultiplier应使用Multiplier该类进行计算x * y * z。为了做到这一点,它首先计算x * y(通过Multiplier.Begin/EndMultiply),然后将结果乘以z。当然,可以在任何步骤Multiplier.EndMultiply抛出SomeException哪个计算失败。x * y * z

实现这一点的最佳(或好的)方法是什么?有没有图案?

4

2 回答 2

4

在编写新代码时,我会避免使用 APM(异步编程模型:使用 IAsyncResult 和 Begin* 和 End*)。

在 Visual Studio 2010 中,引入了任务并行库 (TPL),同时引入了任务异步模式 (TAP)。这种模式是支持 VS 2012 (C# 5) 中新的 async/await 关键字的底层框架 API 的基础。您可以使用 Task.FromAsync(); 包装 APM 实现;但如果您正在编写新代码,那么使用 Task/Task 将是未来更好的选择。

使用 TAP,您可以使用 Task 对象包装委托,该对象将异步执行委托。然后,您可以“继续”其他异步任务,这些任务将在第一个委托完成时运行。例如,如果您有两个委托,其中一个需要在另一个完成时运行,您可以这样做:

        Task.Factory.StartNew(() => MyMethod())
            .ContinueWith(() => MyOtherMethod());

您可以将其包装在一个方法中:

public void AsyncCompound(Action firstAcction, Action secondAction)
{
            Task.Factory.StartNew(firstAction)
                .ContinueWith(secondAction);
}

...比定义 IAsyncResult 类和实现 Begin 和 End 方法的工作要少得多。

至于 .NET 3.5——流行的模式是 APM——没有始终可用的“任务”类。有一些 TPL 实现可能有效,但我没有使用它们。或者,您可以查看Reactive Extensions,因为它是实现异步操作的另一种方式——尽管是基于事件的。

APM 会很快变得冗长,因此,我建议尽可能使用委托。我还建议重新使用 IAsyncResult 实现,例如http://msdn.microsoft.com/en-us/magazine/cc163467.aspx上的实现 例如:

public class Multiplier
{
    public LargeNumber Multiply(LargeNumber x, LargeNumber y)
    {
        return x * y;
    }

    public IAsyncResult BeginMultiply(LargeNumber x, LargeNumber y, AsyncCallback callback, object state)
    {
        AsyncResult<LargeNumber> ar = new AsyncResult<BigInteger>(callback, state);
        ThreadPool.QueueUserWorkItem(o =>
        {
            var asyncResult = (AsyncResult<LargeNumber>)o;
            try
            {
                var largeNumber = Multiply(x, y);
                asyncResult.SetAsCompleted(largeNumber, false);
            }
            catch (Exception e)
            {
                asyncResult.SetAsCompleted(e, false);
            }
        }, ar);
        return ar;
    }

    public LargeNumber EndMultiply(IAsyncResult asyncResult)
    {
        var ar = (AsyncResult<LargeNumber>)asyncResult;

        return ar.EndInvoke();
    }

    public IAsyncResult BeginMultiply(LargeNumber x, LargeNumber y, LargeNumber z, AsyncCallback callback, object state)
    {
        AsyncResult<LargeNumber> ar = new AsyncResult<LargeNumber>(callback, state);

        BeginMultiply(x, y, (asyncResult1) =>
        {
            var firstResult = EndMultiply(asyncResult1);
            BeginMultiply(firstResult, z, (asyncResult2) =>
            {
                var secondResult = EndMultiply(asyncResult2);
                ar.SetAsCompleted(secondResult, true);
            }, state);
        }, state);
        return ar;
    }
}

然后可以按如下方式使用它来异步计算一个值并返回到当前线程:

var asyncResult = multiplier.BeginMultiply(x, y, z, ar => { }, null);
var result = multiplier.EndMultiply(asyncResult);

或者,您可以链接到要在后台线程上执行的其他代码:

        multiplier.BeginMultiply(x, y, z, ar =>
                                          {
                                            var result = multiplier.EndMultiply(ar);
                                            /* TODO: something with result on this background thread */
                                          }, null);

...由您决定如何在需要的地方获得该结果,以及如何与调用 BeginMultiply 的线程交互(如果有的话)。

于 2012-06-23T04:00:11.273 回答
1

如果您想实现其他一些组合异步操作的好方法 - 请查看 Richter 的Simplified APM With The AsyncEnumerator下一部分,它允许使用创建的迭代器编写几乎顺序的代码yield

该库从 Wintellect 网站下载。

使用示例 -使用 AsyncEnumerator

于 2012-06-23T04:47:06.130 回答