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
для возвращения целых чисел из последовательности. Чтобы вызывать этот метод, добавьте следующий код:
