C#学习教程:如何使用.NET 4中的任务并行库链接异步操作?分享


如何使用.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) { //? } 

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

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

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

 precedingTask.ContinueWith(Task nextTask) 

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

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

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

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

上述就是C#学习教程:如何使用.NET 4中的任务并行库链接异步操作?分享的全部内容,如果对大家有所用处且需要了解更多关于C#学习教程,希望大家多多关注—猴子技术宅(www.ssfiction.com)

本文来自网络收集,不代表猴子技术宅立场,如涉及侵权请点击右边联系管理员删除。

如若转载,请注明出处:https://www.ssfiction.com/ckf/1031633.html

发表评论

邮箱地址不会被公开。 必填项已用*标注