Чтение текстового файла асинхронно

Question

Простите мое невежество, но я с проблемами понимания отрывок MSDN для чтения содержимого файла асинхронно

https://msdn.microsoft.com/en-us/library/jj155757.aspx

string text = await ReadTextAsync(filePath); 

...

private async Task<string> ReadTextAsync(string filePath) 
{ 
    using (FileStream sourceStream = new FileStream(filePath, 
     FileMode.Open, FileAccess.Read, FileShare.Read, 
     bufferSize: 4096, useAsync: true)) 
    { 
     StringBuilder sb = new StringBuilder(); 

     byte[] buffer = new byte[0x1000]; 
     int numRead; 
     while ((numRead = await sourceStream.ReadAsync(buffer, 0, buffer.Length)) != 0) 
     { 
      string text = Encoding.Unicode.GetString(buffer, 0, numRead); 
      sb.Append(text); 
     } 

     return sb.ToString(); 
    } 
} 

Как что чтение асинхронно? Похоже, дождаться завершения ReadTextAsync, чтобы вернуть содержимое. Если в этом методе вставлен Thread.Sleep, он будет ждать завершения, и после вызова метода этот код не будет работать.

Answer 1

Проблема заключалась в отсутствии понимания от меня о модификаторе async. Исходный пример выполняется асинхронно, но любой дополнительный медленный код завершения, добавленный в этот метод, будет работать синхронно и ждать завершения вызывающего потока. Если бы действительно был нужен Sleep, тогда весь вызов мог быть завернут в новый Task и вызван, возвращая задачу, а не результат.

Это не приостанавливает выполнение программы, например, когда вы читаете внешний диск.

public Task<string> ReadTextAsync(string filePath) 
    { 
     var task = new Task<string>(() => 
     { 
      Thread.Sleep(5000); 
      using (FileStream sourceStream = new FileStream(filePath, 
FileMode.Open, FileAccess.Read, FileShare.Read, 
bufferSize: 4096, useAsync: true)) 
      { 
       StringBuilder sb = new StringBuilder(); 

       byte[] buffer = new byte[0x1000]; 
       int numRead; 
       while ((numRead = sourceStream.Read(buffer, 0, buffer.Length)) != 0) 
       { 
        string text = Encoding.ASCII.GetString(buffer, 0, numRead); 
        sb.Append(text); 
       } 

       return sb.ToString(); 
      } 
     }); 
     task.Start(); 
     return task; 
    } 

Answer 2

В оболочке гайки await убедитесь, что для операций ввода-вывода (например, запросы к базе данных, чтения файлов, записи в сети и т. Д.), Что поток отсылается обратно на O/S, в то время как код ожидает результата на завершение порт. Таким образом ваши потоки или не сидят вокруг indling, ожидая завершения ввода-вывода, теперь они могут повторно использоваться O/S для других действий. По завершении ввода/вывода O/S переназначает новый поток ИЛИ использует исходный поток (в зависимости от ConfigureAwait), чтобы возобновить операцию.

Так что это не параллельное или параллельное программирование, оно просто позволяет потоку обслуживать другие запросы, пока процесс (кодовая точка) ждет завершения ввода-вывода.

Также см. Asynchronous Programming with Async and Await для получения дополнительной информации.