C＃並行處理選項

Question

我試圖讓我的代碼的一部分並行運行，我試圖在C＃中使用ThreadPool，以避免任何頭痛，但似乎我要求太多的池，我的代碼實際上它運行得更慢！

下面的代碼解釋了我想要做的事情，我有大量的音頻樣本（取決於緩衝區大小從512-> 4096的任何地方），需要插入，傳播和讀取節點（從n = 4到n = 16）。這必須以樣本爲基礎進行，因此我唯一的優化選擇是對網絡中存在的每個節點採用插入/傳播/讀取並具有並行操作的部分。該操作在每個遊戲幀中調用一次，並且在遊戲的整個生命週期中都需要。看一下剖析器，散射操作需要大量的時間，所以它是一個很好的候選者（我已經完成了傳統的優化）。目前，我有一個線程池工作人員爲一個工作項目中的所有節點完成工作，只是爲了啓動和運行，但稍後可以拆分工作。

我認爲下面的代碼的問題是插入到線程池的工作項的頻率，我也讀過某些地方，線程需要一段時間才能旋轉起來，所以如果線程池創建更多，它不neccserally幫助。有沒有人有任何其他並行處理方法的建議，或可以發現我的線程池實施的任何錯誤？

public void propagateNetwork() { 

    int numSampsToConsume = Mathf.min(inSamples.Count,buffersize); 

    for (int i = 0; i < numSampsToConsume; i++) { 
     outVal = 0.0f; 
     inVal = inSamples.Dequeue() * networkInScale; 

     directDelay.write (inVal); 
     directVal = directDelay.read(); 
     directVal *= directAtt; 

     for (j = 0; j < network.Count; j++) { 
      outVal += network [j].getOutgoing(); 
      network [j].inputIncoming (inVal); 
     } 

     ThreadPool.QueueUserWorkItem (scatteringThreadPoolWrapper); 
     scatteringThreadDone.WaitOne(); 

     outVal += directVal; 
     outSamples.Enqueue (outVal); 
    } 
} 

public void scatteringThreadPoolWrapper(object threadConext) { 
    doScatteringForNodeRange (0, network.Count); 
} 

public void doScatteringForNodeRange(int min,int max) { 
    for (int i = min; i < max; i++) { 
     network[i].doScattering (doLateReflections); 
    } 
    scatteringThreadDone.Set(); 
} 

Answer 1

也許使用Parallel.for會工作嗎？我在每個循環迭代中都創建了一些本地變量，但我不知道這些操作都在做什麼，以及如果這些操作可能會導致問題（如果並行運行）。

public void propagateNetwork() { 
    int numSampsToConsume = Mathf.min(inSamples.Count,buffersize); 

    Parallel.for(0, numSampsToConsume, i => { 
     var outVal = 0.0f; 
     var inVal = inSamples.Dequeue() * networkInScale; 

     directDelay.write (inVal); 
     var directVal = directDelay.read(); 
     directVal *= directAtt; 

     Parallel.for(0, network.Count, j => { 
      outVal += network [j].getOutgoing(); 
      network [j].inputIncoming (inVal); 
     }); 

     doScatteringForNodeRange (0, network.Count); 

     outVal += directVal; 
     outSamples.Enqueue (outVal); 
    }); 
}