Aszinkron fájl I/O
Az aszinkron műveletek lehetővé teszik az erőforrás-igényes I/O-műveletek végrehajtását a fő szál blokkolása nélkül. Ez a teljesítménybeli szempont különösen fontos egy Windows 8.x Áruházbeli vagy asztali alkalmazásban, ahol egy időigényes streamelési művelet blokkolhatja a felhasználói felületi szálat, és úgy jelenik meg, mintha az alkalmazás nem működna.
A 4.5-ös .NET-keretrendszer kezdve az I/O-típusok aszinkron metódusokat tartalmaznak az aszinkron műveletek egyszerűsítéséhez. Az aszinkron metódus a nevében szerepel Async
, például ReadAsync: , WriteAsync, CopyToAsync, FlushAsync, ReadLineAsyncés ReadToEndAsync. Ezeket az aszinkron metódusokat streamosztályokon, például Stream, FileStreamés MemoryStream, és olyan osztályokon implementáljuk, amelyek olvasásra vagy streamek írására szolgálnak, például TextReader és TextWriter.
A .NET-keretrendszer 4- és korábbi verzióiban olyan módszereket kell használnia, mint az BeginReadEndRead aszinkron I/O-műveletek implementálása. Ezek a módszerek továbbra is elérhetők a jelenlegi .NET-verziókban az örökölt kód támogatásához; az aszinkron metódusok azonban könnyebben implementálják az aszinkron I/O-műveleteket.
A C# és a Visual Basic két kulcsszóval rendelkezik az aszinkron programozáshoz:
Async
(Visual Basic) vagyasync
(C#) módosító, amely egy aszinkron műveletet tartalmazó metódus megjelölésére szolgál.Await
(Visual Basic) vagyawait
(C#) operátor, amely egy aszinkron metódus eredményére van alkalmazva.
Az aszinkron I/O-műveletek implementálásához használja ezeket a kulcsszavakat az aszinkron metódusokkal együtt, az alábbi példákban látható módon. További információ: Aszinkron programozás aszinkron és várakozási (C#) vagy Aszinkron programozás aszinkron és várakozási (Visual Basic) használatával.
Az alábbi példa bemutatja, hogyan másolhat két FileStream objektumot aszinkron módon a fájlok egyik könyvtárból a másikba. Figyelje meg, hogy a Click vezérlő eseménykezelője Button a módosítóval async
van megjelölve, mert aszinkron metódust hív meg.
using System;
using System.Threading.Tasks;
using System.Windows;
using System.IO;
namespace WpfApplication
{
public partial class MainWindow : Window
{
public MainWindow()
{
InitializeComponent();
}
private async void Button_Click(object sender, RoutedEventArgs e)
{
string startDirectory = @"c:\Users\exampleuser\start";
string endDirectory = @"c:\Users\exampleuser\end";
foreach (string filename in Directory.EnumerateFiles(startDirectory))
{
using (FileStream sourceStream = File.Open(filename, FileMode.Open))
{
using (FileStream destinationStream = File.Create(Path.Combine(endDirectory, Path.GetFileName(filename))))
{
await sourceStream.CopyToAsync(destinationStream);
}
}
}
}
}
}
Imports System.IO
Class MainWindow
Private Async Sub Button_Click(sender As Object, e As RoutedEventArgs)
Dim StartDirectory As String = "c:\Users\exampleuser\start"
Dim EndDirectory As String = "c:\Users\exampleuser\end"
For Each filename As String In Directory.EnumerateFiles(StartDirectory)
Using SourceStream As FileStream = File.Open(filename, FileMode.Open)
Using DestinationStream As FileStream = File.Create(EndDirectory + filename.Substring(filename.LastIndexOf("\"c)))
Await SourceStream.CopyToAsync(DestinationStream)
End Using
End Using
Next
End Sub
End Class
A következő példa hasonló az előzőhöz, de egy szövegfájl tartalmának aszinkron olvasására és StreamWriter írására használja StreamReader az objektumokat és az objektumokat.
private async void Button_Click(object sender, RoutedEventArgs e)
{
string UserDirectory = @"c:\Users\exampleuser\";
using (StreamReader SourceReader = File.OpenText(UserDirectory + "BigFile.txt"))
{
using (StreamWriter DestinationWriter = File.CreateText(UserDirectory + "CopiedFile.txt"))
{
await CopyFilesAsync(SourceReader, DestinationWriter);
}
}
}
public async Task CopyFilesAsync(StreamReader Source, StreamWriter Destination)
{
char[] buffer = new char[0x1000];
int numRead;
while ((numRead = await Source.ReadAsync(buffer, 0, buffer.Length)) != 0)
{
await Destination.WriteAsync(buffer, 0, numRead);
}
}
Private Async Sub Button_Click(sender As Object, e As RoutedEventArgs)
Dim UserDirectory As String = "c:\Users\exampleuser\"
Using SourceReader As StreamReader = File.OpenText(UserDirectory + "BigFile.txt")
Using DestinationWriter As StreamWriter = File.CreateText(UserDirectory + "CopiedFile.txt")
Await CopyFilesAsync(SourceReader, DestinationWriter)
End Using
End Using
End Sub
Public Async Function CopyFilesAsync(Source As StreamReader, Destination As StreamWriter) As Task
Dim buffer(4095) As Char
Dim numRead As Integer
numRead = Await Source.ReadAsync(buffer, 0, buffer.Length)
Do While numRead <> 0
Await Destination.WriteAsync(buffer, 0, numRead)
numRead = Await Source.ReadAsync(buffer, 0, buffer.Length)
Loop
End Function
A következő példa a mögöttes fájlt és a Windows 8.x Áruházbeli alkalmazásokban a fájlok Stream megnyitásához használt XAML-fájlt mutatja be, és az osztály egy példányával olvassa be a StreamReader tartalmát. Aszinkron metódusokkal nyitja meg a fájlt streamként, és felolvassa annak tartalmát.
using System;
using System.IO;
using System.Text;
using Windows.Storage.Pickers;
using Windows.Storage;
using Windows.UI.Xaml;
using Windows.UI.Xaml.Controls;
namespace ExampleApplication
{
public sealed partial class BlankPage : Page
{
public BlankPage()
{
this.InitializeComponent();
}
private async void Button_Click_1(object sender, RoutedEventArgs e)
{
StringBuilder contents = new StringBuilder();
string nextLine;
int lineCounter = 1;
var openPicker = new FileOpenPicker();
openPicker.SuggestedStartLocation = PickerLocationId.DocumentsLibrary;
openPicker.FileTypeFilter.Add(".txt");
StorageFile selectedFile = await openPicker.PickSingleFileAsync();
using (StreamReader reader = new StreamReader(await selectedFile.OpenStreamForReadAsync()))
{
while ((nextLine = await reader.ReadLineAsync()) != null)
{
contents.AppendFormat("{0}. ", lineCounter);
contents.Append(nextLine);
contents.AppendLine();
lineCounter++;
if (lineCounter > 3)
{
contents.AppendLine("Only first 3 lines shown.");
break;
}
}
}
DisplayContentsBlock.Text = contents.ToString();
}
}
}
Imports System.Text
Imports System.IO
Imports Windows.Storage.Pickers
Imports Windows.Storage
NotInheritable Public Class BlankPage
Inherits Page
Private Async Sub Button_Click_1(sender As Object, e As RoutedEventArgs)
Dim contents As StringBuilder = New StringBuilder()
Dim nextLine As String
Dim lineCounter As Integer = 1
Dim openPicker = New FileOpenPicker()
openPicker.SuggestedStartLocation = PickerLocationId.DocumentsLibrary
openPicker.FileTypeFilter.Add(".txt")
Dim selectedFile As StorageFile = Await openPicker.PickSingleFileAsync()
Using reader As StreamReader = New StreamReader(Await selectedFile.OpenStreamForReadAsync())
nextLine = Await reader.ReadLineAsync()
While (nextLine <> Nothing)
contents.AppendFormat("{0}. ", lineCounter)
contents.Append(nextLine)
contents.AppendLine()
lineCounter = lineCounter + 1
If (lineCounter > 3) Then
contents.AppendLine("Only first 3 lines shown.")
Exit While
End If
nextLine = Await reader.ReadLineAsync()
End While
End Using
DisplayContentsBlock.Text = contents.ToString()
End Sub
End Class
<Page
x:Class="ExampleApplication.BlankPage"
xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
xmlns:local="using:ExampleApplication"
xmlns:d="http://schemas.microsoft.com/expression/blend/2008"
xmlns:mc="http://schemas.openxmlformats.org/markup-compatibility/2006"
mc:Ignorable="d">
<StackPanel Background="{StaticResource ApplicationPageBackgroundBrush}" VerticalAlignment="Center" HorizontalAlignment="Center">
<TextBlock Text="Display lines from a file."></TextBlock>
<Button Content="Load File" Click="Button_Click_1"></Button>
<TextBlock Name="DisplayContentsBlock"></TextBlock>
</StackPanel>
</Page>