多个线程中的 For 循环

Question

如何在另一个线程中运行每个 for 循环调用，但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 循环 - 在此解释。

Answer 2

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

Answer 3

一种方法是使用 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 循环本身都被视为并行工作项（毕竟它位于与其他工作项不同的线程上），以避免第一个工作项可能出现的非常微妙的竞争条件。工作项在下一个工作项排队之前发出该事件信号。

Answer 4

对于 .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 类型模式，因此连接的顺序并不重要被处决。