for循環在很多線程

Question

如何在另一個線程中運行每個循環的調用，但ExternalMethod的繼續應該等待for循環（和同步）的最後一個工作線程的結束？

ExternalMethod() 
{ 
    //some calculations 
    for (int i = 0; i < 10; i++) 
    { 
     SomeMethod(i); 
    } 
    //continuation ExternalMethod 
} 

Answer 1

一種方法是使用ManualResetEvent。

考慮下面的代碼（注意，這不應該被視爲一個工作示例，貼在OSX所以不必VS也不是C＃編譯器將手按這種過度）：

static ManualResetEvent mre = new ManualResetEvent(false); 
static int DoneCount = 0; 
static int DoneRequired = 9; 
void ExternalMethod() { 
     mre.Reset(); 
     for (int i = 0; i < 10; i++) { 
       new Thread(new ThreadStart(ThreadVoid)).Start(); 
     } 
     mre.WaitOne(); 
} 

void ThreadVoid() { 
     Interlocked.Increment(ref DoneCount); 

     if (DoneCount == DoneRequired) { 
       mre.Set(); 
     } 
} 

重要提示 - 這可能不是最好的方式，只是使用ManualResetEvent的一個例子，它會滿足您的需求。

如果您使用.NET 4.0，則可以使用Parallel.For循環 - explained here。

Answer 2

System.Threading.Tasks.Parallel.For(0, 10, (i) => SomeMethod(i)); 

Answer 3

對於.NET 3.5，也許是這樣的：

Thread[] threads = new Thread[10]; 

for (int x = 0; x < 10; x++) 
{ 
    threads[x] = new Thread(new ParameterizedThreadStart(ThreadFun)); 
    threads[x].Start(x); 
} 

foreach (Thread thread in threads) thread.Join(); 

這似乎違反直覺使用Join()的方法，但因爲你是有效的做了WaitAll型模式，它不重要的是執行連接的順序。

Answer 4

一種方法是使用CountdownEvent。

ExternalMethod() 
{ 
    //some calculations 
    var finished = new CountdownEvent(1); 
    for (int i = 0; i < 10; i++) 
    { 
     int capture = i; // This is needed to capture the loop variable correctly. 
     finished.AddCount(); 
     ThreadPool.QueueUserWorkItem(
      (state) => 
      { 
      try 
      { 
       SomeMethod(capture); 
      } 
      finally 
      { 
       finished.Signal(); 
      } 
      }, null); 
    } 
    finished.Signal(); 
    finished.Wait(); 
    //continuation ExternalMethod 
} 

如果CountdownEvent不可用，那麼這是另一種方法。

ExternalMethod() 
{ 
    //some calculations 
    var finished = new ManualResetEvent(false); 
    int pending = 1; 
    for (int i = 0; i < 10; i++) 
    { 
     int capture = i; // This is needed to capture the loop variable correctly. 
     Interlocked.Increment(ref pending); 
     ThreadPool.QueueUserWorkItem(
      (state) => 
      { 
      try 
      { 
       SomeMethod(capture); 
      } 
      finally 
      { 
       if (Interlocked.Decrement(ref pending) == 0) finished.Set(); 
      } 
      }, null); 
    } 
    if (Interlocked.Decrement(ref pending) == 0) finished.Set(); 
    finished.WaitOne(); 
    //continuation ExternalMethod 
} 

注意，在這兩個例子中for環本身是治療對象的並行工作項目（這是從畢竟其他工作項目一個單獨的線程），以避免如果第一個可能出現的一個非常微妙的競爭條件工作項目在下一個工作項目排隊之前通知事件。