Семафорная дроссельная заслонка с асинхронным/ожиданием

Question

Недавно я наткнулся на пример дросселирования потоков для вызовов async/await. После анализа и игры с кодом на моей машине я придумал несколько другой способ сделать то же самое. Что я не уверен в том, что то, что происходит под капотом, почти одинаково или если есть какие-то тонкие различия, которые стоит отметить?

Вот код, основанный на оригинальном примере:

private readonly SemaphoreSlim _semaphore = new SemaphoreSlim(5); 

public async Task CallThrottledTasks() 
{ 
    var tasks = new List<Task>(); 

    for (int count = 1; count <= 20; count++) 
    { 
     await _semaphore.WaitAsync(); 

     tasks.Add(Task.Run(async() => 
      { 
       try 
       { 
        int result = await LongRunningTask(); 
        Debug.Print(result.ToString()); 
       } 
       finally 
       { 
        _semaphore.Release(); 
       } 
      })); 
    } 

    await Task.WhenAll(tasks); 

    Debug.Print("Finished CallThrottledTasks"); 
} 

И вот мое взятие на том же коде:

private readonly SemaphoreSlim _semaphore = new SemaphoreSlim(5); 

public async Task CallThrottledTasks() 
{ 
    var tasks = new List<Task>(); 

    for (int count = 1; count <= 20; count++) 
    { 
     await _semaphore.WaitAsync(); 

     tasks.Add(LongRunningTask().ContinueWith(t => 
     { 
      try 
      { 
       int result = t.Result; 
       Debug.Print(result.ToString()); 
      } 
      finally 
      { 
       _semaphore.Release(); 
      } 
     })); 
    } 

    await Task.WhenAll(tasks); 

    Debug.Print("Finished CallThrottledTasks"); 
} 

Я, вероятно, далеко, но кажется, как Task. Подход Run создает задачу для запуска LongRunningTask(), а затем добавляет продолжение для печати результата, тогда как мой подход обходит задачу, созданную Task.Run, и в результате становится немного более компактным. Является ли это точным или я отсюда?

Answer 1

Это не намного более компактный, немного. Обычно я избегаю ContinueWith в async код, потому что await чище и имеет более async -дружественная по умолчанию семантика. Сначала оптимизируйте время разработки, а затем оптимизируйте для других соображений.

Ваш код слегка изменяет семантику: в исходном коде LongRunningTask был выполнен из контекста пула потоков, а в вашем коде он выполнен из любого контекста CallThrottledTasks. Кроме того, ваш код не будет распространять исключения из LongRunningTask чисто; Task<T>.Result обертывает исключения в AggregateException, а await не будет делать никаких оберток.