큐를 모니터링하는 가장 효율적인 방법

Question

큐를 모니터링하는 가장 효율적인 방법은 무엇입니까?

코드의 때라도 조각 자원의 가장 큰 돼지입니다 :

/// <summary> 
/// Starts the service. 
/// </summary> 
private void StartService() 
{ 
    while (true) 
    { 
     //the check on count is not thread safe 
     while (_MessageQueue.Count > 0) 
     { 
      Common.IMessage message; 
      // the call to GetMessageFromQueue is thread safe 
      if (_MessageQueue.GetMessageFromQueue(out message) == true) 
      { 
       if (message.RoutingInfo == Devices.Common.MessageRoutingInfo.ToDevice) 
       { 
        _Port.SerialPort.WriteLine(message.Message); 
       } 
       if (message.RoutingInfo == Devices.Common.MessageRoutingInfo.FromDevice) 
       { 
        OnDeviceMessageReceived(new Common.DeviceMessageArgs(message.Message)); 
       } 
      } 
     } 
    } 
} 

시작 서비스는 백그라운드 스레드에서 실행 _MessageQueue.Count에 대한 호출이 스레드로부터 안전하지 않습니다, 나는 MessageQueue가에 카운트에 고정하고 있지 않다. 그러나 _MessageQueue.GetMessageFromQueue 구현을 잠급니다. 이 방법이 효과적 이었습니까? 오히려 이벤트를 발생시켜야합니까? 큐가 0부터 0보다 커질 때마다?

Answer 1

아마 그 유형으로 스레드 수면을 포함해야합니다. 그렇지 않으면 100 % CPU를 사용하게됩니다. 또는 대기 핸들을 작성하여 대기열에 메시지를 추가 할 때 대기 핸들을 설정할 수 있습니다.

Answer 2

아무 것도 놓치지 않은 경우 - _messageQueue.Count 속성에서 바쁜 대기 중입니다. 대신에 적극적으로 폴링 http://msdn.microsoft.com/en-us/library/yy12yx1f.aspx

Answer 3

큐가 당신이하는 데 도움이 NetMsmqBinding

http://msdn.microsoft.com/en-us/library/ms789008.aspx

희망과 직접 WCF에 MSMQ 메시지를 소비 할 수 있습니다에서 이루어처럼 나는 무언가를 시도 할 것입니다.

Answer 4

코드에서 _MessageQueue 만 사용 되었습니까? 메시지를 사용할 수있을 때까지

public class BlockingMessageQueue { 
    private readonly MyMessageQueue queue; 
    private readonly Semaphore signal; 

    public BlockingMessageQueue(MyMessageQueue queue) { 
    this.queue = queue; 
    this.signal = new Semaphore(0, int.MaxValue); 
    } 

    public void Enqueue(IMessage message) { 
    lock (this.queue) { 
     this.queue.Send(message); 
    } 
    this.signal.Release(); 
    } 

    public IMessage Dequeue() { 
    this.signal.WaitOne(); 
    IMessage message; 
    lock (this.queue) { 
     var success = this.queue.GetMessageFromQueue(out message); 
     Debug.Assert(success); 
    } 
    return message; 
    } 
} 

Dequeue이 차단됩니다, 그래서 메시지를 사용할 수없는 경우에는 낭비 사이클이 없습니다 : 그럼 당신은 이런 클래스에 포장 할 수있다.

사용 예 : 당신이 프로듀서를 통해 어떠한 제어 할 수없는 경우를 제외하고

var queue = new BlockingMessageQueue(_MessageQueue); 

while (true) { 
    var message = queue.Dequeue(); 

    if (message.RoutingInfo == Devices.Common.MessageRoutingInfo.ToDevice) 
    { 
    _Port.SerialPort.WriteLine(message.Message); 
    } 
    else if (message.RoutingInfo == Devices.Common.MessageRoutingInfo.FromDevice) 
    { 
    OnDeviceMessageReceived(new Common.DeviceMessageArgs(message.Message)); 
    } 
}