Язык программирования C#9 и платформа .NET5

  var outputDirectory =
    Path.Combine(basePath, "ModifiedPictures");
  // Удалить любые существующие файлы
  if (Directory.Exists(outputDirectory))
  {
    Directory.Delete(outputDirectory, true);
  }
  Directory.CreateDirectory(outputDirectory);
  string[] files = Directory.GetFiles(
    pictureDirectory, "*.jpg", SearchOption.AllDirectories);
  try
  {
    foreach(string file in files)
    {
      try
      {
        await ProcessFile(
         file, outputDirectory,_cancelToken.Token);
      }
      catch (OperationCanceledException ex)
      {
        Console.WriteLine(ex);
        throw;
      }
    }
  }
  catch (OperationCanceledException ex)
  {
    Console.WriteLine(ex);
    throw;
  }
  catch (Exception ex)
  {
    Console.WriteLine(ex);
    throw;
  }
  _cancelToken = null;
  this.Title = "Processing complete";
}
После начальных настроек в коде организуется цикл по файлам с асинхронным вызовом метода 
ProcessFile()
 для каждого файла. Вызов метода 
ProcessFile()
 помещен внутрь блока 
try/catch
 и ему передается объект 
CancellationToken
. Если вызов 
Cancel()
 выполняется на 
CancellationTokenSource
 (т.е. когда пользователь щелкает на кнопке Cancel), тогда генерируется исключение 
OperationCanceledException
.
На заметку! Код 
try/catch
 может находиться где угодно в цепочке вызовов (как вскоре вы увидите). Размещать его при первом вызове или внутри самого асинхронного метода — вопрос личных предпочтений и нужд приложения.
Наконец, добавьте финальный метод 
ProcessFile()
:
private async Task ProcessFile(string currentFile,
  string outputDirectory, CancellationToken token)
{
 
  string filename = Path.GetFileName(currentFile);
  using (Bitmap bitmap = new Bitmap(currentFile))
  {
    try
    {
      await Task.Run(() =>
      {
        Dispatcher?.Invoke(() =>
        {
          this.Title = $"Processing {filename}";
        });
        bitmap.RotateFlip(RotateFlipType.Rotate180FlipNone);
        bitmap.Save(Path.Combine(outputDirectory, filename));
      }
     ,token);
    }
    catch (OperationCanceledException ex)
    {
      Console.WriteLine(ex);
      throw;
    }
  }
}
Метод 
ProcessFile()
 использует еще одну перегруженную версию 
Task.Run()
, которая принимает в качестве параметра объект 
CancellationToken
. Вызов 
Task.Run()
 помещен внутрь блока 
try/catch
 (как и вызывающий код) на случай щелчка пользователем на кнопке Cancel.
  
Асинхронные потоки (нововведение в версии 8.0)
 
В версии C# 8.0 появилась возможность создания и потребления потоков данных (раскрываются в главе 20) асинхронным образом. Метод, который возвращает асинхронный поток данных:
• объявляется с модификатором 
async
;
• возвращает реализацию 
IAsyncEnumerable<T>
;
• содержит операторы 
yield return
 (рассматривались в главе 8) для возвращения последовательных элементов в асинхронном потоке данных.
Взгляните на приведенный далее пример:
public static async IAsyncEnumerable<int> GenerateSequence()
{
 
  for (int i = 0; i < 20; i++)
  {
   await Task.Delay(100);
    yield return i;
  }
}
Метод 
GenerateSequence()
 объявлен как 
async
, возвращает реализацию 
IAsyncEnumerable<int>
 и применяет 
yield return
 для возвращения целых чисел из последовательности. Чтобы вызывать этот метод, добавьте следующий код: