为什么在这个例子中线程连接的行为有所不同？

Question

更新的问题更通用：

我有以下代码。当你交换线程[i] .Join（）的位置时，你会得到不同的输出。

static void ThreadedWorker(int startIndex, int endIndex) 
{ 
    Console.WriteLine("Working from results[ " + startIndex +"] to results["+endIndex+"]"); 
} 

static void Main(string[] args) 
{ 
    int threadCount = System.Environment.ProcessorCount; 
    int calculationCount = 500; //the number of array elements we'd be iterating over if we were doing our work 
    int threadDataChunkSize = calculationCount/threadCount; 
    if (threadDataChunkSize < 1) threadDataChunkSize = 1; //just in case we have loads of threads 

    Thread[] threads = new Thread[threadCount]; 
    for (int i = 0; i < threadCount; i++) 
    { 
     threads[i] = new Thread(() => ThreadedWorker(threadDataChunkSize * i, threadDataChunkSize*(i+1))); 
     threads[i].Start(); 
     //threads[i].Join(); //****Uncomment for correct behaviour**** 
    } 

    for (int i = 0; i < threadCount; i++) 
    { 
     //threads[i].Join(); //****Uncomment for incorrect behaviour**** 
    } 

    Console.WriteLine("breakhere"); 
} 

当Join()在第一循环中，创造连续的行为，你得到的输出

Working from results[ 0] to results[125] 
Working from results[ 125] to results[250] 
Working from results[ 250] to results[375] 
Working from results[ 375] to results[500] 

当Join()是在第二循环中，建立一个平行的行为，你会得到不确定性的输出是这样的：

Working from results[ 375] to results[500] 
Working from results[ 375] to results[500] 
Working from results[ 500] to results[625] 
Working from results[ 500] to results[625] (i is sometimes more than it should ever be!) 

我怀疑lambda表达式以某种方式导致问题。希望这个改写也表明这不是一个界限的错误计算，或者其他滥用我的数组！

---

最初的问题不是通用的，而是使用startIndex和endIndex遍历一个正在工作的字节数组。我将ThreadedWorker描述为“不工作”，因为它似乎有时会更新结果数组，有时不会。现在看来，它被称为，但起始索引和endindex被打破。

Answer 1

你的解决方案是正确的，但你误解了问题。

Lambda表达式是线程安全的。

但是，所有的lambda表达式都共享相同的i变量。
因此，如果其中一个线程恰好在循环移动到下一次迭代之后开始，它将拾取较新的值i。

通过在循环中声明一个单独的变量，你迫使每个lambda使用自己的变量，它永远不会改变。

Answer 2

第一个代码Join s在启动它之后，在开始下一个线程之前。

因此，所有的线程按顺序运行。

第二个代码立即运行所有的线程，然后Join所有的一次。

因此，线程同​​时运行在完全相同的数据上。

第二个代码可能不起作用，因为您的代码或数据不是线程安全的。

Answer 3

为了完成我的问题的更新，我深入了解它的底部。随着lambda表达式不是线程安全的，我需要我存储在每个循环迭代一个临时变量：

for (int i = 0; i < threadCount; i++) 
{ 
    int temp = i; 
    threads[temp] = new Thread(() => ThreadedMultiplier(threadDataChunkSize * temp, threadDataChunkSize * (temp + 1))); 
threads[temp].Start(); 
} 

for (int i = 0; i < threadCount; i++) 
{ 
    //threads[i].Join(); //****Uncomment for correct + parallel behaviour at last!**** 
}