무한 마 ... 루프 내가 다음 코드 한 비동기 기다리고 있습니다

Question

를 사용하는 동안 : 내가 비동기 MemoryStream로 작성 Stream을 읽으려고하고 있지만, Do...while 루프가 휴식 실패

public static async Task<string> ReadLineAsync(this Stream stream, Encoding encoding) 
{ 
byte[] byteArray = null; 
using (MemoryStream ms = new MemoryStream()) 
{ 
    int bytesRead= 0; 
    do 
    { 
     byte[] buf = new byte[1024]; 
     try 
     { 
      bytesRead = await stream.ReadAsync(buf, 0, 1024); 
      await ms.WriteAsync(buf, 0, bytesRead); 
     } 
     catch (Exception e) 
     { 
      Console.WriteLine(e.Message + e.StackTrace); 
     } 
    } while (stream.CanRead && bytesRead> 0); 

    byteArray = ms.ToArray(); 
    return encoding.GetString(ms.ToArray()); 
} 

. 나는 그것이 무한 루프라는 것을 의미한다. 어떻게 해결할 수 있을까요?

Answer 1

CanRead가 true이고 bytesRead가 0 이상이면 루프 조건이 실행되도록 설정되어 있습니다. CanRead는 파일을 읽을 수있는 경우 항상 true입니다. 즉, 읽는 동안 바이트가 항상 0보다 커야합니다. 읽을 수있는 최대 바이트 수와 최소한의 다른 컨트롤을 설정해야합니다.

Answer 2

첫째, 예외적 인 상황에서 루프가 무기한 계속됩니다. 예외를 포착하고 무시해서는 안됩니다.

두 번째로 스트림이 실제로 끝이 아닌 경우 bytesRead은 절대로 0이되지 않습니다. 메서드의 이름 (ReadLineAsync)이 스트림의 끝까지 읽을 수 있다는 것을 내게 암시하지 않기 때문에 이것이 맞는 것 같습니다.

P. CanRead은 특정 스트림에 대해 변경되지 않습니다. 읽기 작업을 수행하는 스트림에 의미 론적 의미가 있는지 여부가 아닌지 여부는 지금을 읽을 수 있는지 여부가 아닙니다.

Answer 3

나는 당신의 방법을 데리고 다음 호출 예상대로

public static async Task<string> ReadLineAsync(this Stream stream, Encoding encoding) 
    { 
     const int count = 2; 
     byte[] byteArray = Enumerable.Empty<byte>().ToArray(); 
     using (MemoryStream ms = new MemoryStream()) 
     { 
      int bytesRead = 0; 
      do 
      { 
       byte[] buf = new byte[count]; 
       try 
       { 
        bytesRead = await stream.ReadAsync(buf, 0, count); 
        await ms.WriteAsync(buf, 0, bytesRead); 
        Console.WriteLine("{0:ffffff}:{1}:{2}",DateTime.Now, stream.CanRead, bytesRead); 
       } 
       catch (Exception e) 
       { 
        Console.WriteLine(e.Message + e.StackTrace); 
       } 
      } while (stream.CanRead && bytesRead > 0); 

      byteArray = ms.ToArray(); 
      return encoding.GetString(byteArray); 
     } 
    } 

하지만 기본적으로이 일을 몇 가지 디버그 문을 읽기 버퍼 크기를 단축하고 추가하여 단지 약간 그것을 수정 :

private static void Main(string[] args) 
    { 
     FileStream stream = File.OpenRead(@"C:\in.txt"); 
     Encoding encoding = Encoding.GetEncoding(1252); 
     Task<string> result = stream.ReadLineAsync(encoding); 
     result.ContinueWith(o => 
      { 
       Console.Write(o.Result); 
       stream.Dispose(); 
      }); 

     Console.WriteLine("Press ENTER to continue..."); 
     Console.ReadLine(); 
    } 

그래서 당신의 입력 파일로 뭔가 될 수 궁금해? 광산

one 
two 
three 

(메모장 ++에서 윈도우 1252으로 인코딩) 한 내 출력은 어떻게

Press ENTER to continue... 
869993:True:2 
875993:True:2 
875993:True:2 
875993:True:2 
875993:True:2 
875993:True:2 
875993:True:2 
875993:True:1 
875993:True:0 
one 
two 
three 

참고했다 "Enter를 눌러서 계속 ..."주요 방법 때문에 예상대로 먼저 인쇄 된 비동기 적으로 호출되었고 CanRead은 파일이 읽을 수 있음을 나타 내기 때문에 항상 true입니다. 커서가 EOF에있는 것을 의미하는 것이 아니라 파일이 열린 상태입니다.

Answer 4

그래서 IMAP에서 스트림을 가져 오는 중입니다.이 방법은 해당 증기를 텍스트로 변환하는 것입니까?
SteamReader를 스트림 주위에 구성하고 ReadToEndAsync 또는 ReadToEnd 만 호출하면 어떨까요? 이 스트림을 비동기 작업으로 만드는 필요성을 의심합니다. 스트림이 전자 메일과 비슷한 경우 사용자가 읽는 동안 UI가 차단되는 것을 사용자가 눈치 채지 못할 정도로 커지지는 않습니다.
의견에서 알 수 있듯이 UI 앱이 아닌 경우 문제가 될 수 있습니다.

내 가정이 틀린 경우이 기능의 사용 방법에 대한 추가 정보를 묻는 질문을 할 수 있습니다. 더 많은 정보를 주시면 더 나은 답변을 얻을 수 있습니다.

EDIT : 코드에서 줄 끝 부분을 찾을 수는 없지만 사용자의 메서드가 ReadLineAsync라는 것을 알게되었습니다. 텍스트 줄을 읽으려는 의도가 있다면 SteamReader는 ReadLine 및 ReadLineAsync도 제공합니다. 코드는 다음을 수행하려고처럼 내 POV에서

Answer 5

은 같습니다

• 1024 옥텟 청크의 순서로 전체 스트림을 읽을
• 의 (a MemoryStream로 모든 청크를 연결하여, 어떤 바이트 배열을 보조 저장소로 사용)
• 지정된 인코딩
• 을 사용하여 MemoryStream을 MemoryStream으로 변환하여 호출자에게 반환합니다.

이것은 ... 나에게 복잡해 보입니다. 어쩌면 내가 누락되었지만 async 및 await을 사용하려면 VS2012 및 .Net 4.5 또는 VS2010을 사용해야합니다. 닷넷 4.0과 비동기 CTP, 그렇지? 그렇다면 왜 StreamReader과 StreamReader.ReadToEndAsync() 방법을 사용하지 않는 것이 좋을까요?

public static async Task<string> MyReadLineAsync(this Stream stream, Encoding encoding) 
{ 
    using (StreamReader reader = new StreamReader(stream , encoding)) 
    { 
    return await reader.ReadToEndAsync() ; 
    } 
} 

중첩 I/O 아이디어 좋지만 메모리 스트림에 기입하는데 필요한 시간은 실제 peform받는 필요한 시간에 대하여 차이의 하나 엉 있도록 최소한 충분하지 말이며 I/O (아마도 당신의 입력 스트림이 디스크 나 네트워크 I/O를하고있다).