MessageQueueとAsync/Await

Question

メッセージを非同期メソッドで受信したいだけです。私のUIがフリーズしています

public async void ProcessMessages() 
    { 
     MessageQueue MyMessageQueue = new MessageQueue(@".\private$\MyTransactionalQueue"); 
     MyMessageQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) }); 

     while (true) 
     { 
      MessageQueueTransaction MessageQueueTransaction = new MessageQueueTransaction(); 
      MessageQueueTransaction.Begin(); 

      ContainError = false; 
      ProcessPanel.SetWaiting(); 

      string Body = MyMessageQueue.Receive(MessageQueueTransaction).Body.ToString(); 

      //Do some process with body string. 

      MessageQueueTransaction.Commit(); 
     } 
    } 

私はちょうど通常の方法のようにメソッドを呼び出しています！ このコードは、async/awaitの代わりにBackgroundWorkersを使用していたときに使用されました。

アイデア？

Answer 1

スティーブンが書いているように、非同期スレッドでコードを実行されません。幸いなことに、あなたは非同期メッセージを受信するためにMessageQueue.BeginReceive /MessageQueue.EndReceiveでTaskFactory.FromAsyncを使用することができます。

private async Task<Message> MyAsyncReceive() 
    { 
     MessageQueue queue=new MessageQueue(); 
     ... 
     var message=await Task.Factory.FromAsync<Message>(
          queue.BeginReceive(), 
          queue.EndReceive); 

     return message; 

    } 

あなたは、トランザクションを使用していますBeginReceiveのバージョンが存在していないが、ことに注意してください。 BeginReceiveのドキュメントから：

トランザクションで非同期呼び出しBeginReceiveを使用しないでください。トランザクション非同期操作を実行する場合は、BeginPeekを呼び出して、peek操作用に作成したイベントハンドラ内にトランザクションメソッドと（同期）Receiveメソッドを配置します。

これは、応答を待たなければならない期間や、最終的に完了した通話を処理するスレッドが保証されないため意味があります。

は、あなたがこのような何か書くとトランザクションを使用するには、次の

private async Task<Message> MyAsyncReceive() 
    { 
     var queue=new MessageQueue(); 

     var message=await Task.Factory.FromAsync<Message>(queue.BeginPeek(),queue.EndPeek); 

     using (var tx = new MessageQueueTransaction()) 
     { 
      tx.Begin(); 

      //Someone may have taken the last message, don't wait forever 
      //Use a smaller timeout if the queue is local 
      message=queue.Receive(TimeSpan.FromSeconds(1), tx); 
      //Process the results inside a transaction 
      tx.Commit(); 
     } 
     return message; 
    } 

UPDATEをロブが指摘したように、元のコードが使用さ

Peekの間で変更された可能性があるPeekから返さmessage、およびReceive。この場合、2番目のメッセージは失われます。

他のクライアントがキュー内の最後のメッセージを読み取ると、ブロックされる可能性があります。これを防ぐには、Receiveのタイムアウト値を小さくする必要があります。

Answer 2

async does not run your code on a background thread.上記のコードでは、メソッドが同期して実行されることを示すコンパイラの警告が表示されるはずです。

あなたがTaskEx.Runを使用して、バックグラウンドスレッドでメソッドを実行する場合：

public void ProcessMessages() 
{ 
    ... 
} 

TaskEx.Run(() => ProcessMessages());