명백한 BufferBlock.Post/Receive/ReceiveAsync 인종/버그

Question

은 정말 최대 잠재력을 TplDataflow를 사용하지 않는 ... http://social.msdn.microsoft.com/Forums/en-US/tpldataflow/thread/89b3f71d-3777-4fad-9c11-50d8dc81a4a9

내가 알고 교차 기록했다. ATM 단순히 메시지 전달을위한 안전한 대기열로 BufferBlock을 사용하고 있습니다. 여기서 생산자와 소비자는 다른 속도로 실행됩니다. 하는 방법에 관해서는 저를 곤란하게 만드는 이상한 행동을보고 있습니다. (2000 라인 분산 솔루션의 일부입니다) 위의 코드에서

private BufferBlock<object> messageQueue = new BufferBlock<object>(); 

public void Send(object message) 
{ 
    var accepted=messageQueue.Post(message); 
    logger.Info("Send message was called qlen = {0} accepted={1}", 
    messageQueue.Count,accepted); 
} 

public async Task<object> GetMessageAsync() 
{ 
    try 
    { 
     var m = await messageQueue.ReceiveAsync(TimeSpan.FromSeconds(30)); 
     //despite messageQueue.Count>0 next line 
     //occasionally does not execute 
     logger.Info("message received"); 
     //....... 
    } 
    catch(TimeoutException) 
    { 
     //do something 
    } 
} 

는 Send 주기적으로 100ms마다 정도라고되고있다. 즉, 항목은 Post이고 messageQueue은 초당 약 10 회입니다. 확인되었습니다. 그러나 때때로 ReceiveAsync이 시간 초과 (즉 Post은 ReceiveAsync을 완료하지 못함)를 완료하지 못하고 30 초 후에 TimeoutException이 발생하는 경우가 있습니다. 이 시점에서 messageQueue.Count은 수백입니다. 예상치 못한 결과입니다. 이 문제는 게시 속도가 느린 경우 (1 초당 1 회) 관찰되었으며 일반적으로 1000 개 항목이 BufferBlock을 통과하기 전에 발생합니다.

그래서이 문제를 해결, 내가 일 다음과 같은 코드를 사용하고 작동,하지만

public async Task<object> GetMessageAsync() 
    { 
     try 
     { 
      object m; 
      var attempts = 0; 
      for (; ;) 
      { 
       try 
       { 
        m = await messageQueue.ReceiveAsync(TimeSpan.FromSeconds(1)); 
       } 
       catch (TimeoutException) 
       { 
        attempts++; 
        if (attempts >= 30) throw; 
        continue; 
       } 
       break; 

      } 

      logger.Info("message received"); 
      //....... 
     } 
     catch(TimeoutException) 
     { 
      //do something 
     } 
    } 

이 경쟁 조건처럼 보이는 (로 인해 발생하는 위의 버그) 수신 할 때 가끔 1 초 지연이 발생 TDF에서 나에게,하지만 내가 왜 BufferBlock 유사한 방식으로 사용하는 다른 장소에서 발생하지 않습니다의 바닥에 도착할 수 없습니다. 실험적으로 ReceiveAsync에서 Receive으로 변경하는 것은 도움이되지 않습니다. 나는 체크하지 않았지만 위와 같은 코드가 완벽하게 작동한다는 것을 별도로 상상한다. 그것은 "TPL 데이터 흐름 소개"tpldataflow.docx에 문서화 된 패턴입니다.

내가이 일을 처리하기 위해 무엇을 할 수 있습니까? 무슨 일이 일어나는지 추측하는 데 도움이되는 통계가 있습니까? 신뢰할 수있는 테스트 케이스를 만들 수 없다면 어떤 정보를 더 제공 할 수 있습니까?

도움말!

Answer 1

스티븐은 다음의 해결책이라고 생각하는 것 같다

var에 m = messageQueue.ReceiveAsync()을 기다리고 있습니다;

대신 :

VAR의 m = 기다리고 messageQueue.ReceiveAsync (TimeSpan.FromSeconds (30));

당신이 이것을 확인 또는 부인할 수 있습니까?