如何使用.NET 4中的任务并行库链接异步操作？

我正在尝试以编程方式将C＃4中的异步操作链接起来，例如写入给定的Stream对象。 我最初是“手动”执行此操作，将回调从一个操作挂钩到下一个操作，但我想我会尝试使用.NET 4任务并行库来省去重新发明并发轮的麻烦。

首先，我将异步调用包装在Tasks中，如下所示：

public static Task CreateWriteTask(Stream stream, byte[] data) { return Task.Factory.FromAsync(stream.BeginWrite, stream.EndWrite, data, 0, data.Length, null); } 

Continuations使链接同步操作变得非常容易（如果您原谅不幸的方法名称）：

 public static Task ChainFlush(Stream stream, Task precedingTask) { return precedingTask.ContinueWith(x => stream.Flush()); } 

但是没有Task.ContinueWith方法的版本以与Task.ContinueWith相同的方式接受异步操作。

所以，假设我坚持使用TPL，我正在寻找这种方法的正确实现：

 public static Task ChainWrite(Stream stream, byte[] data, Task precedingTask) { //? } 

Answer 1

到目前为止，我最好的想法是链接新写入任务的创建，然后使用Unwrap扩展方法将Task转回Task ：

 public static Task ChainWrite(Stream stream, byte[] data, Task precedingTask) { return precedingTask.ContinueWith(x => CreateWriteTask(stream, data)).Unwrap(); } 

Answer 2

据我了解，这是一个不幸的结果，即无法控制任务何时开始。 由于您永远不知道任务何时开始，因此不会出现过载等问题

 precedingTask.ContinueWith(Task nextTask) 

因为一旦创建，它可能已经在你进入’ContinueWith’时启动。 此外，它也会造成一堆乱七八糟的类型。 这里的类型应该是什么：

 precedingTask.ContinueWith(Task<..what?..> nextTask) 

在返回一个T，所以接下来取什么并返回什么？ :)这可以通过闭包来解决。

Answer 3

尝试ContinueWhenAll()或ContinueWhenAny()而不是ContinueWith() 。 看到这里 。