인가 거기에 파일 스트림과 같은 블록

Question

은 내가이 인터페이스를 구현하는 객체 제공 필요로하는 라이브러리를 사용하고 있음을 메모리 스트림에서 :

public interface IConsole { 
    TextWriter StandardInput { get; } 
    TextReader StandardOutput { get; } 
    TextReader StandardError { get; } 
} 

개체의 독자는 다음 라이브러리에 의해 익숙해를 :

IConsole console = new MyConsole(); 
int readBytes = console.StandardOutput.Read(buffer, 0, buffer.Length); 

일반적으로 IConsole을 구현하는 클래스는 외부 프로세스에서 온 것으로 StandardOutput 스트림을 가지고 있습니다. 이 경우 console.StandardOutput.Read 호출은 StandardOutput 스트림에 기록 된 데이터가있을 때까지 블로킹하여 작동합니다.

내가하려고하는 것은 MemoryStreams를 사용하는 Test IConsole 구현을 만들고 StandardInput에 StandardInput에 나타나는 모든 것을 echo하는 것입니다. 나는 시도 :

MemoryStream echoOutStream = new MemoryStream(); 
StandardOutput = new StreamReader(echoOutStream); 

그러나 문제는 일부 데이터가 될 때까지 console.StandardOutput.Read 블록보다는 0을 반환합니다. 어쨌든 사용할 수있는 데이터가 없거나 사용할 수있는 메모리 스트림이 다른 경우 차단할 MemoryStream을 얻을 수 있습니까?

Answer 1

결국 MemoryStream을 상속하고 읽기 및 쓰기 메서드를 인계 받아 쉽게 수행 할 수있는 방법을 발견했습니다. 연속적으로 기록 할 수있는없이, 버전 당신이 쓰기에 따라 스트림을 읽어야와

public class EchoStream : MemoryStream 
{ 
    private readonly ManualResetEvent _DataReady = new ManualResetEvent(false); 
    private readonly ConcurrentQueue<byte[]> _Buffers = new ConcurrentQueue<byte[]>(); 

    public bool DataAvailable{get { return !_Buffers.IsEmpty; }} 

    public override void Write(byte[] buffer, int offset, int count) 
    { 
     _Buffers.Enqueue(buffer); 
     _DataReady.Set(); 
    } 

    public override int Read(byte[] buffer, int offset, int count) 
    { 
     _DataReady.WaitOne(); 

     byte[] lBuffer; 

     if (!_Buffers.TryDequeue(out lBuffer)) 
     { 
      _DataReady.Reset(); 
      return -1; 
     } 

     if (!DataAvailable) 
      _DataReady.Reset(); 

     Array.Copy(lBuffer, buffer, lBuffer.Length); 
     return lBuffer.Length; 
    } 
} 

: 당신의 대답에 영감을

는

public class EchoStream : MemoryStream { 

    private ManualResetEvent m_dataReady = new ManualResetEvent(false); 
    private byte[] m_buffer; 
    private int m_offset; 
    private int m_count; 

    public override void Write(byte[] buffer, int offset, int count) { 
     m_buffer = buffer; 
     m_offset = offset; 
     m_count = count; 
     m_dataReady.Set(); 
    } 

    public override int Read(byte[] buffer, int offset, int count) { 
     if (m_buffer == null) { 
      // Block until the stream has some more data. 
      m_dataReady.Reset(); 
      m_dataReady.WaitOne();  
     } 

     Buffer.BlockCopy(m_buffer, m_offset, buffer, offset, (count < m_count) ? count : m_count); 
     m_buffer = null; 
     return (count < m_count) ? count : m_count; 
    } 
} 

Answer 2

, 여기 내 다중 스레드, 다중 쓰기 버전입니다. 제 버전은 ConcurrentQueue에 서면 버퍼를 버퍼링합니다 (간단한 큐로 변경하고 잠그는 것이 매우 간단합니다)