在编写新代码时,我会避免使用 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 的线程交互(如果有的话)。