Один из подходов, который можно использовать для предоставления вторичным потокам доступа к элементам управления в безопасной к потокам манере, предусматривает применение другого приема — анонимного делегата. Родительский класс Control в WPF определяет объект Dispatcher, который управляет рабочими элементами для потока. Указанный объект имеет метод по имени Invoke(), принимающий на входе System.Delegate. Этот метод можно вызывать внутри кода, выполняющегося во вторичных потоках, чтобы обеспечить возможность безопасного в отношении потоков обновления пользовательского интерфейса для заданного элемента управления. В то время как весь требуемый код делегата можно было бы написать напрямую, большинство разработчиков используют в качестве простой альтернативы синтаксис выражений. Вот как выглядит модифицированный код:

// Этот код больше не работает!

// this.Title = $"Processing {filename} on thread {Thread.

//              CurrentThread.ManagedThreadld}";

// Вызвать Invoke() на объекте Dispatcher, чтобы позволить вторичным потокам

// получать доступ к элементам управления в безопасной к потокам манере.

Dispatcher?.Invoke(() =>

{

  this.Title = $"Processing {filename}";

});

using (Bitmap bitmap = new Bitmap(currentFile))

{

 bitmap.RotateFlip(RotateFlipType.Rotate180FlipNone);

  bitmap.Save(Path.Combine(outputDirectory, filename));

}

Теперь после запуска программы библиотека TPL распределит рабочую нагрузку по множеству потоков из пула, используя столько процессоров, сколько возможно. Тем не менее, поскольку заголовок Title всегда обновляется из главного потока, код обновления Title больше не отображает текущий поток, и при вводе в текстовой области вы ничего не увидите до тех пор, пока не обработаются все файлы изображений! Причина в том, что первичный поток пользовательского интерфейса по-прежнему блокируется, ожидая завершения работы всех остальных потоков.

Класс Task

Класс Task позволяет легко вызывать метод во вторичном потоке и может применяться как простая альтернатива асинхронным делегатам. Измените обработчик события Click элемента управления Button следующим образом:

private void cmdProcess_Click(object sender, EventArgs e)

{

  // Запустить новую "задачу" для обработки файлов.

  Task.Factory.StartNew(() => ProcessFiles());

  // Можно записать и так:

  // Task.Factory.StartNew(ProcessFiles);

}

Свойство Factory класса Task возвращает объект TaskFactory. Методу StartNew() при вызове передается делегат Action (что здесь скрыто с помощью подходящего лямбда-выражения), указывающий на метод, который подлежит вызову в асинхронной манере. После такой небольшой модификации вы обнаружите, что заголовок окна отображает информацию о потоке из пула, обрабатывающем конкретный файл, а текстовое поле может принимать ввод, поскольку пользовательский интерфейс больше не блокируется.

Обработка запроса на отмену

В текущий пример можно внести еще одно улучшение — предоставить пользователю способ для останова обработки данных изображений путем щелчка на второй кнопке 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();

}