MSMQ - ReceiveCompleted - Сообщения процесса async

Question

Я использую метод BeginnReceive и обработчик событий ReceiveCompleted для прослушивания и обработки сообщений из MSMQ.

Я положил метод BeginReceive в начале обработчика событий ReceiveCompleted.

Похоже, он отлично работает в моем консольном приложении. Прямо сейчас сообщения обрабатываются асинхронно.

Вопрос: Является ли это безопасным в отношении безопасности резьбы?
Все примеры, которые я видел, вызывают вызов BeginReceive до конца обработчика пройденного события. Поэтому я спрашиваю себя, есть ли какие-либо проблемы, когда ставить его в самом начале обработанного обработчика?

private void InitializeQueue() 
{ 
    try 
    { 
     _mq = MessageQueue.GetPrivateQueuesByMachine(_queueServerName).Where(qu => qu.Path == _queueAddress).FirstOrDefault(); 
     _mq.Formatter = new BinaryMessageFormatter(); 
     _mq.ReceiveCompleted += MessageReceiveCompleted; 

    } 
    catch (Exception ex) 
    { 
     Trace.WriteLine("Failed to initialize Queue!" + Environment.NewLine + " Error:" + Environment.NewLine + ex.Message); 
     throw; 
    } 
} 


async void MessageReceiveCompleted(object sender, ReceiveCompletedEventArgs e) 
{ 
    _mq.BeginReceive(); 
    try 
    {  
     await ProcessMessageAsync(e.Message); 
    } 
    catch (Exception ex) 
    { 
     Trace.WriteLine("Error occured during report fetching:" + Environment.NewLine + ex.Message); 
     throw; 
    } 
} 

Answer 1

Да, ваш подход с async/await будет обрабатывать потоки safeely.C# асинхронный подход с этими ключевыми словами будет зависеть. Более конкретно о моем ответе метод обработчика события messagereceived (имя метода должен заканчиваться асинхронными вызовами) и ожидает по асинхронному методу, если в этом методе есть какая-либо блокирующая работа, поток там приостанавливается и выполняется дальше, пока другая работа не завершится и возвращает, как в этом случае async processmessage может блокировать и может быть дальнейшее выполнение вызова, но я не вижу, чтобы вы использовали его, поскольку после вызова processmessageasync вы ничего не делаете, поэтому поток будет выполняться, если вы спросите, является ли это потокобезопасным да, но асинхронный подход не полностью задействован.