如何在另一个线程中运行每个 for 循环调用，但 ExternalMethod 的延续应该等待 for 循环中最后一个工作线程的结束（并同步）？
ExternalMethod()
{
//some calculations
for (int i = 0; i < 10; i++)
{
SomeMethod(i);
}
//continuation ExternalMethod
}
【问题讨论】：
标签： c# multithreading .net-3.5 loops thread-safety
一种方法是使用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。
【讨论】：
Interlocked.Increment 而不是++ 吗？我虽然 ++ 不安全。
++ vs Interlocked.Increment，因为共享的 DoneCount 存在争用，++ 总是错误的。它不依赖任何东西，++ 在这种情况下总是一个错误。
System.Threading.Tasks.Parallel.For(0, 10, (i) => SomeMethod(i));
【讨论】：
一种方法是使用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 循环本身都被视为并行工作项（毕竟它与其他工作项位于单独的线程上）以避免在第一个工作项时可能发生的非常微妙的竞争条件在下一个工作项排队之前发出事件信号。
【讨论】：
对于 .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 类型的模式，因此执行连接的顺序无关紧要。
【讨论】：