Обработка запроса на отмену
В текущий пример можно внести еще одно улучшение — предоставить пользователю способ для останова обработки данных изображений путем щелчка на второй кнопке Cancel (Отмена). К счастью, методы Parallel.For() и Parallel.ForEach() поддерживают отмену за счет использования маркеров отмены. При вызове методов на объекте Parallel им можно передавать объект ParallelOptions, который в свою очередь содержит объект CancellationTokenSource.
Первым делом определите в производном от Window классе закрытую переменную-член _cancelToken типа CancellationTokenSource:
public partial class MainWindow :Window
{
// Новая переменная уровня Window.
private CancellationTokenSource _cancelToken =
new CancellationTokenSource();
...
}
Обновите обработчик события Click:
private void cmdCancel_
Click(object sender, EventArgs e)
{
// Используется для сообщения всем рабочим потокам о необходимости останова!
_cancelToken.Cancel();
}
Теперь можно заняться необходимыми модификациями метода ProcessFiles(). Вот его финальная реализация:
private void ProcessFiles()
{
<b> // Использовать экземпляр ParallelOptions для хранения CancellationToken.</b>
ParallelOptions parOpts = new ParallelOptions();
parOpts.CancellationToken = _cancelToken.Token;
parOpts.MaxDegreeOfParallelism = System.Environment.ProcessorCount;
// Загрузить все файлы *.jpg и создать новый каталог
// для модифицированных данных.
string[] files = Directory.GetFiles(@".TestPictures", "*.jpg",
SearchOption.AllDirectories);
string outputDirectory = @".ModifiedPictures";
Directory.CreateDirectory(outputDirectory);
try
{
// Обработать данные изображения в параллельном режиме!
Parallel.ForEach(files, parOpts, currentFile =>
{
parOpts
.CancellationToken.ThrowIfCancellationRequested();
(window.adrunTag = window.adrunTag || []).push({v: 1, el: 'adrun-4-390', c: 4, b: 390})
string filename = Path.GetFileName(currentFile);
Dispatcher?.Invoke(() =>
{
this.Title =
$"Processing {filename}
on thread {Thread.CurrentThread.ManagedThreadId}";
});
using (Bitmap bitmap = new Bitmap(currentFile))
{
bitmap.RotateFlip(RotateFlipType.Rotate180FlipNone);
bitmap.Save(Path.Combine(outputDirectory, filename));
}
});
Dispatcher?.Invoke(()=>this.Title = "Done!");
}
catch (OperationCanceledException ex)
{
Dispatcher?.Invoke(()=>this.Title = ex.Message);
}
}
Обратите внимание, что в начале метода конфигурируется объект ParallelOptions с установкой его свойства CancellationToken для применения маркера CancellationTokenSource. Кроме того, этот объект ParallelOptions передается во втором параметре методу Parallel.ForEach().
Внутри логики цикла осуществляется вызов ThrowIfCancellationRequested() на маркере отмены, гарантируя тем самым, что если пользователь щелкнет на кнопке Cancel, то все потоки будут остановлены ив качестве уведомления сгенерируется исключение времени выполнения. Перехватив исключение OperationCanceledException, можно добавить в текст главного окна сообщение об ошибке.
Обеспечение параллелизма задач с помощью класса Parallel
В дополнение к обеспечению параллелизма данных библиотека TPL также может использоваться для запуска любого количества асинхронных задач с помощью метода Parallel.Invoke(). Такой подход немного проще, чем применение делегатов или типов из пространства имен System.Threading, но если нужна более высокая степень контроля над выполняемыми задачами, тогда следует отказаться от использования Parallel.Invoke() и напрямую работать с классом Task, как делалось в предыдущем примере.
Чтобы взглянуть на параллелизм задач в действии, создайте новый проект консольного приложения по имени MyEBookReader и импортируйте в начале файла Program.cs пространства имен System.Threading, System.Text, System.Threading.Tasks, System.Linq и System.Net (пример является модификацией полезного примера из документации по .NET Core). Здесь мы будем извлекать публично доступную электронную книгу из сайта проекта Гутенберга (www.gutenberg.org) и затем параллельно выполнять набор длительных задач. Книга загружается в методе GetBook(), показанном ниже:
