爲什麼在這個例子中線程連接的行爲有所不同？

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!**** 
}