C# : Compact Framework에서 AsyncWaitHandle을 설정하는 방법?

Question

Compact Framework 2.0 응용 프로그램 중 하나에서 TcpClient을 사용하고 있습니다. TCP 서버에서 정보를 받고 싶습니다.

Compact Framework는 "대형"프레임 워크의 시간 초과 메커니즘을 지원하지 않으므로 시간 초과 작업을 구현하려고합니다. 기본적으로, 나는 다음을 수행 할 :

IAsyncResult result = networkStream.BeginRead(buffer, 0, size, ..., networkStream); 
if (!result.AsyncWaitHandle.WaitOne(5000, false)) 
    // Handle timeout 


private void ReceiveFinished(IAsyncResult ar) 
{ 
    NetworkStream stream = (NetworkStream)ar.AsyncState; 
    int numBytes = stream.EndRead(ar); 

    // SIGNAL IASYNCRESULT.ASYNCWAITHANDLE HERE ... HOW?? 
} 

나는 IAsyncResult.AsyncWaitHandle에 대한 Set를 호출하고 싶습니다하지만 이러한 방법이없는 나는이에 캐스팅되는 구현 모른다.

대기 핸들을 어떻게 설정합니까? 또는 EndRead을 호출하여 자동으로 설정됩니까? 설명서는 내가 Set라고 불러야한다고 제안합니다 ...

어떤 도움을 주셔서 감사합니다!

UPDATE
는 EndRead를 호출 할 때 대기 핸들이 자동으로 설정되어 있는지 보인다 -하지만 문서에없는. 누군가 이것을 확인할 수 있습니까? 2

UPDATE 내 샘플 코드에 client.BeginRead를 썼다. 물론 BeginRead이 NetworkStream에 호출되었습니다 ...

Answer 1

저는 TCP로 비동기 IO에 대한 오해가 있다고 생각합니다.

비동기 IO를 시작하려면 stream.BeginRead()를 호출하십시오.
콜백에서 스트림에서 EndRead를 호출합니다.

코드에서 볼 수 있듯이 TcpClient에서 BeginRead를 호출하지 마십시오. 앱이 WaitHandle 신호를 보내지 않습니다. IOth 레이어는 waithandle이 신호를받을 때, 즉 비동기 읽기가 발생할 때 콜백을 호출합니다.

콜백에서 더 많은 데이터를받을 가능성이있는 경우 일반적으로 스트림에서 BeginRead를 다시 호출합니다.

this answer에서 명확한 예를 볼 수 있습니다.

BeginRead/EndRead 댄스를 시작하기 전에 TcpClient에서 비동기 연결을 원할 수 있습니다. 그러면 BeginConnect를 사용할 것입니다. 그러나 그것은 단 한 번만 이루어집니다. 또는 동기 연결을 원할 수도 있습니다.이 경우 TcpClient.Connect()를 호출하면됩니다.

예제 코드 :

private class AsyncState 
    { 
     public NetworkStream ns; 
     public ManualResetEvent e; 
     public byte[] b; 
    } 

    public void Run() 
    { 
     NetworkStream networkStream = ...; 
     byte[] buffer = new byte[1024]; 

     var completedEvent = new ManualResetEvent(false); 

     networkStream.BeginRead(buffer, 0, buffer.Length, 
           AsyncRead, 
           new AsyncState 
           { 
            b = buffer, 
            ns = networkStream, 
            e = completedEvent 
           }); 

     // do other stuff here. ... 

     // finally, wait for the reading to complete 
     completedEvent.WaitOne(); 
    } 


    private void AsyncRead(IAsyncResult ar) 
    { 
     AsyncState state = ar as AsyncState; 
     int n = state.ns.EndRead(ar); 
     if (n == 0) 
     { 
      // signal completion 
      state.e.Set(); 
      return; 
     } 

     // state.buffer now contains the bytes read 
     // do something with it here... 
     // for example, dump it into a filesystem file. 

     // read again 
     state.ns.BeginRead(state.b, 0, state.b.Length, AsyncRead, state); 
    }