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(); 
     } 
    } 

Я просто называю метод, как любой обычный метод, и его nos работают! Этот код работал, когда я использовал BackgroundWorkers вместо async/await

Идеи?

Answer 1

Как пишет Стивен, асинхронная не работает ваш код в потоке. К счастью, вы можете использовать TaskFactory.FromAsync с MessageQueue.BeginReceive /MessageQueue.EndReceive получать сообщения асинхронно:

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 и поместите транзакцию и (синхронный) метод Receive в обработчик событий, который вы создаете для операции peek.

Это имеет смысл, поскольку нет никакой гарантии, сколько времени вам нужно ждать ответа или какой поток в конечном итоге будет обрабатывать завершенный звонок.

Чтобы использовать транзакции можно было бы написать что-то вроде этого:

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

Как Роб отметил, оригинальный код используется message вернулся из Peek, который может быть изменен между Peek и Receive. В этом случае второе сообщение будет потеряно.

По-прежнему существует вероятность блокировки, если другой клиент читает последнее сообщение в очереди. Чтобы предотвратить это, Receive должен иметь небольшой тайм-аут.

Answer 2

async does not run your code on a background thread. Ваш код, указанный выше, должен был вызвать предупреждение о компиляторе, указывающее, что ваш метод будет работать синхронно.

Если вы хотите выполнить метод на фоне потока, используйте TaskEx.Run:

public void ProcessMessages() 
{ 
    ... 
} 

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