Пошаговое руководство. Использование потока данных в приложении Windows Forms

В этой статье показано, как создать сеть блоков потока данных, выполняющих обработку изображений в Windows Forms приложении.

В этом примере файлы изображения загружаются из указанной папки, из них создается составное изображение, и результат отображается. В данном примере для перемещения изображений по сети используется модель потока данных. В модели потока данных независимые компоненты программы взаимодействуют друг с другом, отправляя сообщения. Когда компонент получает сообщение, он выполняет какое-либо действие и затем передает результат другому компоненту. Сравните это с моделью потока управления, в который приложение использует структуры управления, например условные операторы, циклы и т. д., для управления порядком операций в программе.

Предварительные требования

Прежде чем начать выполнение этого пошагового руководства, ознакомьтесь с документом Поток данных.

Разделы

Это пошаговое руководство содержит следующие разделы:

• Создание приложения Windows Forms

• Создание сети потока данных

• Подключение сети потока данных к пользовательскому интерфейсу

• Полный пример

Создание приложения Windows Forms

В этом разделе описывается, как создать простое приложение Windows Forms и добавить элементы управления в главную форму.

Создание приложения Windows Forms

1. В Visual Studio создайте проект Приложение Windows Forms на Visual C# или Visual Basic. В этом документе проект называется CompositeImages.

2. В конструкторе форм главной формы Form1.cs (Form1.vb для Visual Basic) добавьте элемент управления ToolStrip.

3. Добавьте элемент управления ToolStripButton к элементу управления ToolStrip. Задайте свойству DisplayStyle значение Text, а свойству Text — Выбрать папку.

4. Добавьте второй элемент управления ToolStripButton к элементу управления ToolStrip. Задайте свойству DisplayStyleзначение Text, свойству Text значение Отмена, а свойству Enabled — значение False.

5. Добавьте объект PictureBox на главную форму. Задайте свойству Dock значение Fill.

Создание сети потока данных

В этом разделе описывается способ создания сети потока данных, которая выполняет обработку изображений.

Создание сети потока данных

1. В своем проекте добавьте ссылку на System.Threading.Tasks.Dataflow.dll.

2. Убедитесь, что Form1.cs (Form1.vb для Visual Basic) содержит следующие операторы using (Using в Visual Basic).

   using System;
   using System.Collections.Generic;
   using System.Drawing;
   using System.Drawing.Imaging;
   using System.IO;
   using System.Linq;
   using System.Threading;
   using System.Threading.Tasks;
   using System.Threading.Tasks.Dataflow;
   using System.Windows.Forms;
   

3. Добавьте в класс Form1 следующие данные-члены.

   // The head of the dataflow network.
   ITargetBlock<string> headBlock = null;
   
   // Enables the user interface to signal cancellation to the network.
   CancellationTokenSource cancellationTokenSource;
   

4. Добавьте в класс CreateImageProcessingNetwork метод Form1. Этот метод создает сеть обработки изображений.

   // Creates the image processing dataflow network and returns the
   // head node of the network.
   ITargetBlock<string> CreateImageProcessingNetwork()
   {
      //
      // Create the dataflow blocks that form the network.
      //
   
      // Create a dataflow block that takes a folder path as input
      // and returns a collection of Bitmap objects.
      var loadBitmaps = new TransformBlock<string, IEnumerable<Bitmap>>(path =>
         {
            try
            {
               return LoadBitmaps(path);
            }
            catch (OperationCanceledException)
            {
               // Handle cancellation by passing the empty collection
               // to the next stage of the network.
               return Enumerable.Empty<Bitmap>();
            }
         });
   
      // Create a dataflow block that takes a collection of Bitmap objects
      // and returns a single composite bitmap.
      var createCompositeBitmap = new TransformBlock<IEnumerable<Bitmap>, Bitmap>(bitmaps =>
         {
            try
            {
               return CreateCompositeBitmap(bitmaps);
            }
            catch (OperationCanceledException)
            {
               // Handle cancellation by passing null to the next stage
               // of the network.
               return null;
            }
         });
   
      // Create a dataflow block that displays the provided bitmap on the form.
      var displayCompositeBitmap = new ActionBlock<Bitmap>(bitmap =>
         {
            // Display the bitmap.
            pictureBox1.SizeMode = PictureBoxSizeMode.StretchImage;
            pictureBox1.Image = bitmap;
   
            // Enable the user to select another folder.
            toolStripButton1.Enabled = true;
            toolStripButton2.Enabled = false;
            Cursor = DefaultCursor;
         },
         // Specify a task scheduler from the current synchronization context
         // so that the action runs on the UI thread.
         new ExecutionDataflowBlockOptions
         {
             TaskScheduler = TaskScheduler.FromCurrentSynchronizationContext()
         });
   
      // Create a dataflow block that responds to a cancellation request by
      // displaying an image to indicate that the operation is cancelled and
      // enables the user to select another folder.
      var operationCancelled = new ActionBlock<object>(delegate
         {
            // Display the error image to indicate that the operation
            // was cancelled.
            pictureBox1.SizeMode = PictureBoxSizeMode.CenterImage;
            pictureBox1.Image = pictureBox1.ErrorImage;
   
            // Enable the user to select another folder.
            toolStripButton1.Enabled = true;
            toolStripButton2.Enabled = false;
            Cursor = DefaultCursor;
         },
         // Specify a task scheduler from the current synchronization context
         // so that the action runs on the UI thread.
         new ExecutionDataflowBlockOptions
         {
            TaskScheduler = TaskScheduler.FromCurrentSynchronizationContext()
         });
   
      //
      // Connect the network.
      //
   
      // Link loadBitmaps to createCompositeBitmap.
      // The provided predicate ensures that createCompositeBitmap accepts the
      // collection of bitmaps only if that collection has at least one member.
      loadBitmaps.LinkTo(createCompositeBitmap, bitmaps => bitmaps.Count() > 0);
   
      // Also link loadBitmaps to operationCancelled.
      // When createCompositeBitmap rejects the message, loadBitmaps
      // offers the message to operationCancelled.
      // operationCancelled accepts all messages because we do not provide a
      // predicate.
      loadBitmaps.LinkTo(operationCancelled);
   
      // Link createCompositeBitmap to displayCompositeBitmap.
      // The provided predicate ensures that displayCompositeBitmap accepts the
      // bitmap only if it is non-null.
      createCompositeBitmap.LinkTo(displayCompositeBitmap, bitmap => bitmap != null);
   
      // Also link createCompositeBitmap to operationCancelled.
      // When displayCompositeBitmap rejects the message, createCompositeBitmap
      // offers the message to operationCancelled.
      // operationCancelled accepts all messages because we do not provide a
      // predicate.
      createCompositeBitmap.LinkTo(operationCancelled);
   
      // Return the head of the network.
      return loadBitmaps;
   }
   

5. Выполните метод LoadBitmaps.

   // Loads all bitmap files that exist at the provided path.
   IEnumerable<Bitmap> LoadBitmaps(string path)
   {
      List<Bitmap> bitmaps = new List<Bitmap>();
   
      // Load a variety of image types.
      foreach (string bitmapType in
         new string[] { "*.bmp", "*.gif", "*.jpg", "*.png", "*.tif" })
      {
         // Load each bitmap for the current extension.
         foreach (string fileName in Directory.GetFiles(path, bitmapType))
         {
            // Throw OperationCanceledException if cancellation is requested.
            cancellationTokenSource.Token.ThrowIfCancellationRequested();
   
            try
            {
               // Add the Bitmap object to the collection.
               bitmaps.Add(new Bitmap(fileName));
            }
            catch (Exception)
            {
               // TODO: A complete application might handle the error.
            }
         }
      }
      return bitmaps;
   }
   

6. Выполните метод CreateCompositeBitmap.

   // Creates a composite bitmap from the provided collection of Bitmap objects.
   // This method computes the average color of each pixel among all bitmaps
   // to create the composite image.
   Bitmap CreateCompositeBitmap(IEnumerable<Bitmap> bitmaps)
   {
      Bitmap[] bitmapArray = bitmaps.ToArray();
   
      // Compute the maximum width and height components of all
      // bitmaps in the collection.
      Rectangle largest = new Rectangle();
      foreach (var bitmap in bitmapArray)
      {
         if (bitmap.Width > largest.Width)
            largest.Width = bitmap.Width;
         if (bitmap.Height > largest.Height)
            largest.Height = bitmap.Height;
      }
   
      // Create a 32-bit Bitmap object with the greatest dimensions.
      Bitmap result = new Bitmap(largest.Width, largest.Height,
         PixelFormat.Format32bppArgb);
   
      // Lock the result Bitmap.
      var resultBitmapData = result.LockBits(
         new Rectangle(new Point(), result.Size), ImageLockMode.WriteOnly,
         result.PixelFormat);
   
      // Lock each source bitmap to create a parallel list of BitmapData objects.
      var bitmapDataList = (from bitmap in bitmapArray
                            select bitmap.LockBits(
                              new Rectangle(new Point(), bitmap.Size),
                              ImageLockMode.ReadOnly, PixelFormat.Format32bppArgb))
                           .ToList();
   
      // Compute each column in parallel.
      Parallel.For(0, largest.Width, new ParallelOptions
      {
         CancellationToken = cancellationTokenSource.Token
      },
      i =>
      {
         // Compute each row.
         for (int j = 0; j < largest.Height; j++)
         {
            // Counts the number of bitmaps whose dimensions
            // contain the current location.
            int count = 0;
   
            // The sum of all alpha, red, green, and blue components.
            int a = 0, r = 0, g = 0, b = 0;
   
            // For each bitmap, compute the sum of all color components.
            foreach (var bitmapData in bitmapDataList)
            {
               // Ensure that we stay within the bounds of the image.
               if (bitmapData.Width > i && bitmapData.Height > j)
               {
                  unsafe
                  {
                     byte* row = (byte*)(bitmapData.Scan0 + (j * bitmapData.Stride));
                     byte* pix = (byte*)(row + (4 * i));
                     a += *pix; pix++;
                     r += *pix; pix++;
                     g += *pix; pix++;
                     b += *pix;
                  }
                  count++;
               }
            }
   
            //prevent divide by zero in bottom right pixelless corner
            if (count == 0)
                break;
   
            unsafe
            {
               // Compute the average of each color component.
               a /= count;
               r /= count;
               g /= count;
               b /= count;
   
               // Set the result pixel.
               byte* row = (byte*)(resultBitmapData.Scan0 + (j * resultBitmapData.Stride));
               byte* pix = (byte*)(row + (4 * i));
               *pix = (byte)a; pix++;
               *pix = (byte)r; pix++;
               *pix = (byte)g; pix++;
               *pix = (byte)b;
            }
         }
      });
   
      // Unlock the source bitmaps.
      for (int i = 0; i < bitmapArray.Length; i++)
      {
         bitmapArray[i].UnlockBits(bitmapDataList[i]);
      }
   
      // Unlock the result bitmap.
      result.UnlockBits(resultBitmapData);
   
      // Return the result.
      return result;
   }
   

   Примечание

   Версия метода CreateCompositeBitmap в C# использует указатели для обеспечения эффективной обработки объектов System.Drawing.Bitmap. Поэтому необходимо включить параметр Разрешить небезопасный код в проекте для использования ключевого слова небезопасный. Дополнительные сведения о включении небезопасного кода в проекте Visual C# см. в разделе Страница "Сборка" в конструкторе проектов (C#).

Следующая таблица описывает члены сети.

Для подключения блоков потока данных для формирования сети в этом примере используется метод LinkTo. Метод LinkTo содержит перегруженную версию, которая принимает объект Predicate<T>, указывающий, допускает или отклоняет блок целевого объекта определенное сообщение. Этот механизм фильтрации позволяет блокам сообщений получать только определенные значения. В этом примере сеть может разветвляться одним из двух способов. Основная ветвь загружает изображения с диска, создает составное изображение и отображает его на форме. Другая ветвь отменяет текущую операцию. Объекты Predicate<T> позволяют блокам потоков данных, работающим по основной ветви, перейти к альтернативной ветви путем отклонения определенных сообщений. Например, если пользователь отменяет операцию, блок потока данных createCompositeBitmap выводит null (Nothing в Visual Basic). Блок потока данных displayCompositeBitmap отклоняет входные значения null, и поэтому сообщение передается operationCancelled. Блок потока данных operationCancelled принимает все сообщения и поэтому отображает изображение, чтобы показать, что операция отменена.

На следующем рисунке показана сеть обработки изображений:

Поскольку блоки потоков данных displayCompositeBitmap и operationCancelled работают с интерфейсом пользователя, важно, чтобы эти действия происходили в потоке пользовательского интерфейса. Для этого во время построения каждый из этих объектов предоставляет ExecutionDataflowBlockOptions объект , свойство которого TaskScheduler имеет значение TaskScheduler.FromCurrentSynchronizationContext. Метод TaskScheduler.FromCurrentSynchronizationContext создает объект TaskScheduler, выполняющий работу в текущем контексте синхронизации. Так как метод CreateImageProcessingNetwork вызывается из обработчика кнопки Выбрать папку, которая выполняется в потоке пользовательского интерфейса, действия для блоков потока данных displayCompositeBitmap и operationCancelled также выполняются в потоке пользовательского интерфейса.

В этом примере используется общий токен отмены, а не устанавливается свойство CancellationToken, поскольку свойство CancellationToken окончательно отменяет выполнение блока потока данных. Токен отмены в этом примере позволяет повторно использовать те же сети потоков данных несколько раз, даже если пользователь отменил одну или несколько операций. См. пример, который использует CancellationToken, чтобы окончательно отменить выполнение блока потока данных.

Подключение сети потока данных к пользовательскому интерфейсу

В этом разделе описывается, как подключить сеть потока данных к интерфейсу пользователя. Создание составного изображения и отмена операции инициализируются кнопками Выбрать папку и Отмена. Когда пользователь выбирает какую-либо из этих кнопок, соответствующее действие выполняется асинхронно.

Подключение сети потока данных к пользовательскому интерфейсу

1. В конструкторе форм главной формы создайте обработчик событий для события Click кнопки Выбрать папку.

2. Реализуйте событие Click кнопки Выбрать папку.

   // Event handler for the Choose Folder button.
   private void toolStripButton1_Click(object sender, EventArgs e)
   {
      // Create a FolderBrowserDialog object to enable the user to
      // select a folder.
      FolderBrowserDialog dlg = new FolderBrowserDialog
      {
         ShowNewFolderButton = false
      };
   
      // Set the selected path to the common Sample Pictures folder
      // if it exists.
      string initialDirectory = Path.Combine(
         Environment.GetFolderPath(Environment.SpecialFolder.CommonPictures),
         "Sample Pictures");
      if (Directory.Exists(initialDirectory))
      {
         dlg.SelectedPath = initialDirectory;
      }
   
      // Show the dialog and process the dataflow network.
      if (dlg.ShowDialog() == DialogResult.OK)
      {
         // Create a new CancellationTokenSource object to enable
         // cancellation.
         cancellationTokenSource = new CancellationTokenSource();
   
         // Create the image processing network if needed.
         headBlock ??= CreateImageProcessingNetwork();
   
         // Post the selected path to the network.
         headBlock.Post(dlg.SelectedPath);
   
         // Enable the Cancel button and disable the Choose Folder button.
         toolStripButton1.Enabled = false;
         toolStripButton2.Enabled = true;
   
         // Show a wait cursor.
         Cursor = Cursors.WaitCursor;
      }
   }
   

3. В конструкторе форм главной формы создайте обработчик событий для события Click кнопки Отмена.

4. Реализуйте событие Click для кнопки Отмена.

   // Event handler for the Cancel button.
   private void toolStripButton2_Click(object sender, EventArgs e)
   {
      // Signal the request for cancellation. The current component of
      // the dataflow network will respond to the cancellation request.
      cancellationTokenSource.Cancel();
   }
   

Полный пример

В следующем примере приведен полный код для этого руководства.

using System;
using System.Collections.Generic;
using System.Drawing;
using System.Drawing.Imaging;
using System.IO;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using System.Threading.Tasks.Dataflow;
using System.Windows.Forms;

namespace CompositeImages
{
   public partial class Form1 : Form
   {
      // The head of the dataflow network.
      ITargetBlock<string> headBlock = null;

      // Enables the user interface to signal cancellation to the network.
      CancellationTokenSource cancellationTokenSource;

      public Form1()
      {
         InitializeComponent();
      }

      // Creates the image processing dataflow network and returns the
      // head node of the network.
      ITargetBlock<string> CreateImageProcessingNetwork()
      {
         //
         // Create the dataflow blocks that form the network.
         //

         // Create a dataflow block that takes a folder path as input
         // and returns a collection of Bitmap objects.
         var loadBitmaps = new TransformBlock<string, IEnumerable<Bitmap>>(path =>
            {
               try
               {
                  return LoadBitmaps(path);
               }
               catch (OperationCanceledException)
               {
                  // Handle cancellation by passing the empty collection
                  // to the next stage of the network.
                  return Enumerable.Empty<Bitmap>();
               }
            });

         // Create a dataflow block that takes a collection of Bitmap objects
         // and returns a single composite bitmap.
         var createCompositeBitmap = new TransformBlock<IEnumerable<Bitmap>, Bitmap>(bitmaps =>
            {
               try
               {
                  return CreateCompositeBitmap(bitmaps);
               }
               catch (OperationCanceledException)
               {
                  // Handle cancellation by passing null to the next stage
                  // of the network.
                  return null;
               }
            });

         // Create a dataflow block that displays the provided bitmap on the form.
         var displayCompositeBitmap = new ActionBlock<Bitmap>(bitmap =>
            {
               // Display the bitmap.
               pictureBox1.SizeMode = PictureBoxSizeMode.StretchImage;
               pictureBox1.Image = bitmap;

               // Enable the user to select another folder.
               toolStripButton1.Enabled = true;
               toolStripButton2.Enabled = false;
               Cursor = DefaultCursor;
            },
            // Specify a task scheduler from the current synchronization context
            // so that the action runs on the UI thread.
            new ExecutionDataflowBlockOptions
            {
                TaskScheduler = TaskScheduler.FromCurrentSynchronizationContext()
            });

         // Create a dataflow block that responds to a cancellation request by
         // displaying an image to indicate that the operation is cancelled and
         // enables the user to select another folder.
         var operationCancelled = new ActionBlock<object>(delegate
            {
               // Display the error image to indicate that the operation
               // was cancelled.
               pictureBox1.SizeMode = PictureBoxSizeMode.CenterImage;
               pictureBox1.Image = pictureBox1.ErrorImage;

               // Enable the user to select another folder.
               toolStripButton1.Enabled = true;
               toolStripButton2.Enabled = false;
               Cursor = DefaultCursor;
            },
            // Specify a task scheduler from the current synchronization context
            // so that the action runs on the UI thread.
            new ExecutionDataflowBlockOptions
            {
               TaskScheduler = TaskScheduler.FromCurrentSynchronizationContext()
            });

         //
         // Connect the network.
         //

         // Link loadBitmaps to createCompositeBitmap.
         // The provided predicate ensures that createCompositeBitmap accepts the
         // collection of bitmaps only if that collection has at least one member.
         loadBitmaps.LinkTo(createCompositeBitmap, bitmaps => bitmaps.Count() > 0);

         // Also link loadBitmaps to operationCancelled.
         // When createCompositeBitmap rejects the message, loadBitmaps
         // offers the message to operationCancelled.
         // operationCancelled accepts all messages because we do not provide a
         // predicate.
         loadBitmaps.LinkTo(operationCancelled);

         // Link createCompositeBitmap to displayCompositeBitmap.
         // The provided predicate ensures that displayCompositeBitmap accepts the
         // bitmap only if it is non-null.
         createCompositeBitmap.LinkTo(displayCompositeBitmap, bitmap => bitmap != null);

         // Also link createCompositeBitmap to operationCancelled.
         // When displayCompositeBitmap rejects the message, createCompositeBitmap
         // offers the message to operationCancelled.
         // operationCancelled accepts all messages because we do not provide a
         // predicate.
         createCompositeBitmap.LinkTo(operationCancelled);

         // Return the head of the network.
         return loadBitmaps;
      }

      // Loads all bitmap files that exist at the provided path.
      IEnumerable<Bitmap> LoadBitmaps(string path)
      {
         List<Bitmap> bitmaps = new List<Bitmap>();

         // Load a variety of image types.
         foreach (string bitmapType in
            new string[] { "*.bmp", "*.gif", "*.jpg", "*.png", "*.tif" })
         {
            // Load each bitmap for the current extension.
            foreach (string fileName in Directory.GetFiles(path, bitmapType))
            {
               // Throw OperationCanceledException if cancellation is requested.
               cancellationTokenSource.Token.ThrowIfCancellationRequested();

               try
               {
                  // Add the Bitmap object to the collection.
                  bitmaps.Add(new Bitmap(fileName));
               }
               catch (Exception)
               {
                  // TODO: A complete application might handle the error.
               }
            }
         }
         return bitmaps;
      }

      // Creates a composite bitmap from the provided collection of Bitmap objects.
      // This method computes the average color of each pixel among all bitmaps
      // to create the composite image.
      Bitmap CreateCompositeBitmap(IEnumerable<Bitmap> bitmaps)
      {
         Bitmap[] bitmapArray = bitmaps.ToArray();

         // Compute the maximum width and height components of all
         // bitmaps in the collection.
         Rectangle largest = new Rectangle();
         foreach (var bitmap in bitmapArray)
         {
            if (bitmap.Width > largest.Width)
               largest.Width = bitmap.Width;
            if (bitmap.Height > largest.Height)
               largest.Height = bitmap.Height;
         }

         // Create a 32-bit Bitmap object with the greatest dimensions.
         Bitmap result = new Bitmap(largest.Width, largest.Height,
            PixelFormat.Format32bppArgb);

         // Lock the result Bitmap.
         var resultBitmapData = result.LockBits(
            new Rectangle(new Point(), result.Size), ImageLockMode.WriteOnly,
            result.PixelFormat);

         // Lock each source bitmap to create a parallel list of BitmapData objects.
         var bitmapDataList = (from bitmap in bitmapArray
                               select bitmap.LockBits(
                                 new Rectangle(new Point(), bitmap.Size),
                                 ImageLockMode.ReadOnly, PixelFormat.Format32bppArgb))
                              .ToList();

         // Compute each column in parallel.
         Parallel.For(0, largest.Width, new ParallelOptions
         {
            CancellationToken = cancellationTokenSource.Token
         },
         i =>
         {
            // Compute each row.
            for (int j = 0; j < largest.Height; j++)
            {
               // Counts the number of bitmaps whose dimensions
               // contain the current location.
               int count = 0;

               // The sum of all alpha, red, green, and blue components.
               int a = 0, r = 0, g = 0, b = 0;

               // For each bitmap, compute the sum of all color components.
               foreach (var bitmapData in bitmapDataList)
               {
                  // Ensure that we stay within the bounds of the image.
                  if (bitmapData.Width > i && bitmapData.Height > j)
                  {
                     unsafe
                     {
                        byte* row = (byte*)(bitmapData.Scan0 + (j * bitmapData.Stride));
                        byte* pix = (byte*)(row + (4 * i));
                        a += *pix; pix++;
                        r += *pix; pix++;
                        g += *pix; pix++;
                        b += *pix;
                     }
                     count++;
                  }
               }

               //prevent divide by zero in bottom right pixelless corner
               if (count == 0)
                   break;

               unsafe
               {
                  // Compute the average of each color component.
                  a /= count;
                  r /= count;
                  g /= count;
                  b /= count;

                  // Set the result pixel.
                  byte* row = (byte*)(resultBitmapData.Scan0 + (j * resultBitmapData.Stride));
                  byte* pix = (byte*)(row + (4 * i));
                  *pix = (byte)a; pix++;
                  *pix = (byte)r; pix++;
                  *pix = (byte)g; pix++;
                  *pix = (byte)b;
               }
            }
         });

         // Unlock the source bitmaps.
         for (int i = 0; i < bitmapArray.Length; i++)
         {
            bitmapArray[i].UnlockBits(bitmapDataList[i]);
         }

         // Unlock the result bitmap.
         result.UnlockBits(resultBitmapData);

         // Return the result.
         return result;
      }

      // Event handler for the Choose Folder button.
      private void toolStripButton1_Click(object sender, EventArgs e)
      {
         // Create a FolderBrowserDialog object to enable the user to
         // select a folder.
         FolderBrowserDialog dlg = new FolderBrowserDialog
         {
            ShowNewFolderButton = false
         };

         // Set the selected path to the common Sample Pictures folder
         // if it exists.
         string initialDirectory = Path.Combine(
            Environment.GetFolderPath(Environment.SpecialFolder.CommonPictures),
            "Sample Pictures");
         if (Directory.Exists(initialDirectory))
         {
            dlg.SelectedPath = initialDirectory;
         }

         // Show the dialog and process the dataflow network.
         if (dlg.ShowDialog() == DialogResult.OK)
         {
            // Create a new CancellationTokenSource object to enable
            // cancellation.
            cancellationTokenSource = new CancellationTokenSource();

            // Create the image processing network if needed.
            headBlock ??= CreateImageProcessingNetwork();

            // Post the selected path to the network.
            headBlock.Post(dlg.SelectedPath);

            // Enable the Cancel button and disable the Choose Folder button.
            toolStripButton1.Enabled = false;
            toolStripButton2.Enabled = true;

            // Show a wait cursor.
            Cursor = Cursors.WaitCursor;
         }
      }

      // Event handler for the Cancel button.
      private void toolStripButton2_Click(object sender, EventArgs e)
      {
         // Signal the request for cancellation. The current component of
         // the dataflow network will respond to the cancellation request.
         cancellationTokenSource.Cancel();
      }

      ~Form1()
      {
         cancellationTokenSource.Dispose();
      }
   }
}

На следующем рисунке показаны типовые выходные данные для общей папки \Sample Pictures\.

См. также

• Поток данных