17

我正在尝试以编程方式链接 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);
}

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

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

但是没有任何版本的Task.ContinueWith方法可以像TaskFactory.FromAsync.

因此，假设我坚持使用 TPL，我正在寻找此方法的正确实现：

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

3 回答 3

12

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

public static Task ChainWrite(Stream stream, byte[] data, Task precedingTask)
{
    return precedingTask.ContinueWith(x => CreateWriteTask(stream, data)).Unwrap();
}
于 2010-09-07T16:49:30.283 回答
3

据我了解，这是无法控制任务何时开始的不幸后果。由于您永远不知道任务何时开始，因此不会有像这样的重载

precedingTask.ContinueWith(Task nextTask)

因为一旦创建，当您到达“ContinueWith”时它可能已经启动。此外，它还会使类型混乱。这里应该是什么类型：

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

前面返回一个 T，所以 next 接受什么并返回什么？:) 这可以通过闭包来解决。

于 2010-10-16T07:51:42.260 回答
1

尝试ContinueWhenAll()或 ContinueWhenAny()代替ContinueWith(). 见这里。

于 2010-09-07T21:54:21.493 回答