В статье рассматривается: Библиотека распараллеливания заданий Parallel.For или пул потоков Статическое распределение работы Перспективы

Продукты и технологии: Библиотека Parallel FX

 Содержание

Введение в TPL
Структурное параллельное программирование
Излишний параллелизм
Пример моделирования хода лучей
Динамическое распределение работы.
Объединение
Параллелизм ветвления-слияния
Задания и фьючерсы
Реплицируемые задания
Диспетчер заданий

 Figure 1 Статическое распределение работы и явная синхронизация

void ThreadpoolMatrixMult(int size, double[,] m1, double[,] m2, 
    double[,] result)
{
  int N = size;                           
  int P = 2 * Environment.ProcessorCount; // assume twice the procs for 
                                          // good work distribution
  int Chunk = N / P;                      // size of a work chunk
  AutoResetEvent signal = new AutoResetEvent(false); 
  int counter = P;                        // use a counter to reduce 
                                          // kernel transitions    
  for (int c = 0; c < P; c++) {           // for each chunk
    ThreadPool.QueueUserWorkItem(delegate(Object o)
    {
      int lc = (int)o;
      for (int i = lc * Chunk;           // iterate through a work chunk
           i < (lc + 1 == P ? N : (lc + 1) * Chunk); // respect upper 
                                                     // bound
           i++) {
        // original inner loop body
        for (int j = 0; j < size; j++) {
          result[i, j] = 0;
          for (int k = 0; k < size; k++) {
            result[i, j] += m1[i, k] * m2[k, j];
          }
        }
      }
      if (Interlocked.Decrement(ref counter) == 0) { // use efficient 
                                                     // interlocked 
                                                     // instructions      
        signal.Set();  // and kernel transition only when done
      }
    }, c); 
  }
  signal.WaitOne();
}