使用 System.Threading.Tasks.Task而不是流

Question

我在以前版本的 WCF Web API 上使用了如下方法：

// grab the posted stream
Stream stream = request.Content.ContentReadStream;

// write it to   
using (FileStream fileStream = File.Create(fullFileName, (int)stream.Length)) {

    byte[] bytesInStream = new byte[stream.Length];
    stream.Read(bytesInStream, 0, (int)bytesInStream.Length);
    fileStream.Write(bytesInStream, 0, bytesInStream.Length);
}

但是在预览版 6 上，HttpRequestMessage.Content.ContentReadStream 属性消失了。我相信它现在应该看起来像这样：

// grab the posted stream
System.Threading.Tasks.Task<Stream> stream = request.Content.ReadAsStreamAsync();

但我无法弄清楚 using 语句中的其余代码应该是什么样子。谁能给我提供一种方法吗？

Answer 1

您可能必须根据之前/之后发生的代码进行调整，并且没有错误处理，但类似这样：

Task task = request.Content.ReadAsStreamAsync().ContinueWith(t =>
{
    var stream = t.Result;
    using (FileStream fileStream = File.Create(fullFileName, (int) stream.Length)) 
    {
        byte[] bytesInStream = new byte[stream.Length];
        stream.Read(bytesInStream, 0, (int) bytesInStream.Length);
        fileStream.Write(bytesInStream, 0, bytesInStream.Length);
    }
});

如果稍后在代码中，您需要确保此操作已完成，则可以调用 task .Wait() 并且它将阻塞，直到完成（或抛出异常）。

我强烈推荐 Stephen Toub 的并行编程模式来了解.NET 4 中一些新的异步模式（任务、数据并行性等）的速度。

Answer 2

快速而肮脏的修复：

// grab the posted stream
Task<Stream> streamTask = request.Content.ReadAsStreamAsync();
Stream stream = streamTask.Result; //blocks until Task is completed

请注意，同步版本已从 API 中删除这一事实表明您确实应该尝试学习新的异步范例，以避免在高负载下吞噬许多线程。

例如，您可以：

streamTask.ContinueWith( _ => {
    var stream = streamTask.Result; //result already available, so no blocking
    //work with stream here
} )

或使用新的异步等待功能：

//async wait until task is complete
var stream = await request.Content.ReadAsStreamAsync(); 

花时间学习异步/等待。这非常方便。

Answer 3

以下是如何使用 async 和 await 更好地做到这一点：

    private async void WhatEverMethod()
    {
        var stream = await response.Content.ReadAsStreamAsync();

        using (FileStream fileStream = File.Create(fullFileName, (int)stream.Length))
        {
            byte[] bytesInStream = new byte[stream.Length];
            stream.Read(bytesInStream, 0, (int)bytesInStream.Length);
            fileStream.Write(bytesInStream, 0, bytesInStream.Length);
        }
    });