この記事の内容 : : Task Parallel Library Parallel.For と ThreadPool 静的な作業配分 フューチャ

この記事は次のテクノロジを使用しています: Parallel FX Library

 コンテンツ

TPL の概要
構造化並列処理
並列処理を過度に公開する
レイ トレーサの例
動的な作業配分
集計
fork と join の並列実行
タスクとフューチャ
複製可能タスク
タスク マネージャ

 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();
}