复合异步调用-怎么做？
假设我有一个IAsynchronous接口，它支持执行某些操作的两种方法(“开始/结束”模式)：
IAsyncResult BeginOperation(AsyncCallback callback, object state)EndOperation(IAsyncResult ar)
另外，假设我有类A : IAsynchronous和B : IAsynchronous。我必须实现Compound : IAsynchronous类。Compound的操作是调用A的操作，等待它的完成，然后调用B的操作，然后像往常一样调用回调。
问题是如何设计Compound类：
- 我应该保留原始的
state对象，并在Compound的操作完成后调用原始的回调。因此，我不能简单地将它们传递给A.BeginOperation或B.BeginOperation。 - 另外，
Compound.EndOperation应该重新抛出由A.EndOperation或B.EndOperation引发的任何异常。如果A.EndOperation引发了异常，那么Compound的操作不应该调用B.EndOperation，因为复合操作已经失败。 - 如果不仅有两个内部操作，而且有三个或更多的操作呢？有什么共同的办法吗？
为了澄清，请考虑以下示例。假设我们有支持以下方法的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计算失败。
实现这一点的最好(或好的)方法是什么？有什么模式吗？
回答 2
Stack Overflow用户
发布于 2012-06-23 04:00:11
在编写新代码时，我将避免使用APM (异步编程模型:使用IAsyncResult和Begin*和End*)。
在Visual 2010中，引入了任务并行库(TPL)，并引入了任务异步模式(TAP)。此模式是支持VS 2012 (C# 5)中新的异步/等待关键字的底层框架API的基础。您可以用Task.FromAsync()包装APM实现；但是如果您正在编写新代码，那么使用Task/Task将是未来更好的选择。
使用TAP，您可以用一个任务对象包装一个委托，该对象将异步执行委托。然后，您可以使用其他异步任务“继续”，这些任务将在第一个委托完成时运行。例如，如果有两个委托，其中一个在完成另一个委托时需要运行，则可以这样做：
Task.Factory.StartNew(() => MyMethod())
.ContinueWith(() => MyOtherMethod());您可以用一种方法包装它：
public void AsyncCompound(Action firstAcction, Action secondAction)
{
Task.Factory.StartNew(firstAction)
.ContinueWith(secondAction);
}...much减少了定义IAsyncResult类和实现Begin和End方法的工作量。
至于.NET 3.5--流行的模式是APM--没有一致可用的“任务”类。有些TPL实现可能有效，但我还没有使用它们。或者，您可以查看反应性扩展，因为它是实现异步操作的另一种方式--尽管是基于事件的。
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的线程的交互方式(如果有的话)。
Stack Overflow用户
发布于 2012-06-23 04:47:06
如果您想实现其他一些结合异步操作的好方法，请查看Richter的用AsyncEnumerator简化APM和下半部分，它们允许使用使用yield创建的迭代器编写几乎连续的代码。
来自Wintellect站点的图书馆下载。
使用示例- 使用AsyncEnumerator
https://stackoverflow.com/questions/11165840
复制相似问题
腾讯云开发者
