多線程陣列

Question

我有一些線程計數pCount，我有一些float []數組。我想獲得一個指向數組的指針，然後基於pCount創建多個線程並用數據填充數組。

fixed (float* pointer = array) 
{ 
    IntPtr fPtr = new IntPtr(pointer); 

    for (int i = 0; i < pCount; i++) 
    { 
     Thread t = new Thread(() => ThreadMethod(fPtr, blockWidth, blockHeight, xIndex))); 
     t.Start(); 
    } 
} 


private unsafe void ThreadMethod(IntPtr p, int blockWidth, int blockHeight, int startX) 
{ 
    Random RandomGenerator = new Random(); 
    for (int x = startX; x < startX + blockWidth * blockHeight; x++) 
    { 
     ((float*)p)[x] = ((float)(RandomGenerator.NextDouble()) - 0.5f) * 2.0f; 
    } 
} 

因此，如果陣列是1000×1000，我有4個線程我想線程1從0填補數據 - 250那麼線程2 250 - 500，線程3從500 - 750和螺紋4 750 - 1000 。

但我描述的方式沒有工作。誰能幫忙？

Answer 1

沒有必要使用指針運算來訪問C＃中的數組。這裏有一個簡單的例子：

public void ParalellizeArrayFill(int threadCount, float[] array) 
{ 
    if (array == null || array.Length == 0) 
     throw new ArgumentException("Array cannot be empty"); 

    if (threadCount <= 1) 
     throw new ArgumentException("Thread count should be bigger than 1"); 

    int itemsPerThread = array.Length/threadCount; 
    for (int i = 0; i < threadCount; i++) 
    { 
     Thread thread = new Thread((state) => FillArray(array, i*itemsPerThread, itemsPerThread)); 
     thread.Start(); 
    } 
} 

private void FillArray(float[] array, int startIndex, int count) 
{ 
    for (int i = startIndex; i < startIndex + count; i++) 
    { 
     // init value 
     array[i] = value; 
    } 
} 

有幾點需要注意的注意事項。首先，你的部門不可以平分（例如500/3），所以你必須處理這個案子。此外，您不必使用指針算術，因爲數組已經通過引用傳遞並且可以通過索引訪問。