异步内存流方法:以下哪一种



我正在研究使用异步内存流的解决方案,我正在考虑实现这种解决方案的正确方法。哪一个更方便?第一,简单:

//First approach: linear async
private async static Task WriteToStreamFirstVariant()
{
MemoryStream memoryStream = new MemoryStream();
byte[] data = new byte[256];
try
{
await memoryStream.WriteAsync(data, 0, data.Length);
}
catch(Exception exception)
{
//Handling exception
}
finally
{
memoryStream.Dispose();
}
}

或者第二个是嵌套任务和闭包?

//Second approach: nested tasks async
private async static Task WriteToStreamSecondVariant()
{
await Task.Run(async () =>
{
byte[] data = new byte[256];
using (MemoryStream memoryStream = new MemoryStream())
{
await memoryStream.WriteAsync(data, 0, data.Length)
.ContinueWith((Task writingTask) =>
{
//Handling exceptions
AggregateException exceptions = writingTask.Exception;
});
}
}); 
}

事实是MemoryStreamRead/WriteAsync方法实际上并没有提供任何真正的异步实现。他们所做的只是同步执行操作并返回一个已经完成的Task。因此,当您知道它是MemoryStream时,调用异步方法没有任何好处。事实上,这完全是不必要的开销。

现在,暂时忘记了,为了回答你关于风格的问题,第一种方法更好,因为你不会不必要地分配/安排一个新的Task(例如使用Task::Run),但我不知道你为什么不在这种方法中只使用using()语句。下面是最干净/最简单的IMHO:

private async static Task WriteToStreamFirstVariantSimplified()
{
using(MemoryStream memoryStream = new MemoryStream())
{
byte[] data = new byte[256];
try
{
await memoryStream.WriteAsync(data, 0, data.Length);
}
catch(Exception exception)
{
//Handling exception
}
}
}

相关内容

最新更新