Правильный способ использовать Task.Run и подождите

Question

У меня есть ниже блок кода, который в настоящее время запущен с помощью таймера:

private void CheckForScheduleItemsTimerOnElapsed(Object sender, ElapsedEventArgs elapsedEventArgs) 
{ 
    if (CurrentlyProcessingMsgs) 
     return; 

    CurrentlyProcessingMsgs = true; 

    var task = Task.Run(() => { 
      CheckForScheduleItems.Process(_cancellationToken); 
     }, _cancellationToken); 

    task.Wait(_cancellationToken); 

    CurrentlyProcessingMsgs = false; 
} 

Теперь проблема, что я имею, что в некоторых случаях, линия

CurrentlyProcessingMsgs = false; 

не набирается. Насколько я понимаю, Task.Wait должен был дождаться завершения задачи, а затем продолжить, тем самым сбросив этот флаг. Но в некоторых случаях этого не происходит. (Примечание: этот таймер управляется службой.) Что происходит, так это то, что при завершении работы я проверяю значение CurrentProcessingMsgs, и иногда это все еще верно после завершения задачи.

Цель состоит в том, чтобы иметь несколько таймеров, которые срабатывают, как показано выше. Каждый таймер будет обрабатывать аналогично тому, что показано выше, и я хотел бы запускать каждый процесс в отдельном потоке. Я ошибался в своем понимании CancellationToken, поэтому в этом случае было бы правильным способом настроить таймеры и задачи для запуска этих методов и каждого из них в отдельном потоке?

Answer 1

Если _cancellationToken аннулировано, будет произведено исключение. Если вы хотите, чтобы убедиться, что флаг будет изменен, даже если он будет отменен или какое-либо другое возбуждается исключение Process положить CurrentlyProcessingMsgs = false; в попытке /, наконец, блок

private void CheckForScheduleItemsTimerOnElapsed(Object sender, ElapsedEventArgs elapsedEventArgs) 
{ 
    if (CurrentlyProcessingMsgs) 
     return; 

    CurrentlyProcessingMsgs = true; 
    try 
    { 
     var task = Task.Run(() => { 
       CheckForScheduleItems.Process(_cancellationToken); 
      }, _cancellationToken); 

     task.Wait(_cancellationToken); 
    } 
    finally 
    { 
     CurrentlyProcessingMsgs = false; 
    } 
} 

---

P.S. Существует почти никогда не веская причина, чтобы сделать Task.Run, а затем сразу же ждать его. Было бы намного меньше накладных расходов, чтобы просто сделать следующее, которое должно иметь очень похожую логику.

private void CheckForScheduleItemsTimerOnElapsed(Object sender, ElapsedEventArgs elapsedEventArgs) 
{ 
    if (CurrentlyProcessingMsgs) 
     return; 

    CurrentlyProcessingMsgs = true; 
    try 
    { 
     _cancellationToken.ThrowIfCancellationRequested(); 
     CheckForScheduleItems.Process(_cancellationToken); 
    } 
    finally 
    { 
     CurrentlyProcessingMsgs = false; 
    } 
} 

---

Вот обновленная версия с отлов исключения.

private void CheckForScheduleItemsTimerOnElapsed(Object sender, ElapsedEventArgs elapsedEventArgs) 
{ 
    if (CurrentlyProcessingMsgs) 
     return; 

    CurrentlyProcessingMsgs = true; 
    try 
    { 
     _cancellationToken.ThrowIfCancellationRequested(); 
     CheckForScheduleItems.Process(_cancellationToken); 
    } 
    catch (OperationCanceledException ex) 
    { 
     //If the task was canceled for some other reason than our token raise the exception. 
     if(ex.CancellationToken != _cancellationToken) 
      throw; 
    } 
    finally 
    { 
     CurrentlyProcessingMsgs = false; 
    } 
}