在parallel.foreach中使用局部變量

Question

我正在努力解決這個問題。

該代碼應該從文件對話框導入圖像。並且每個圖像都應該被處理併發送給正確的類。 處理器是一個檢測形狀的類，所以基本上我發送每個圖像並檢測其中的形狀（在類處理器內過濾到特定標準）

newList將獲取圖像中所有形狀的中心。

我對並行性知之甚少，我似乎無法想象如何解決這個問題。請記住，我不需要將任何內容從一個迭代傳遞到另一個迭代。我只是希望每次處理和更正圖像，並將整個操作分爲線程。

我的每一次迭代都是獨立的，我不需要從一次迭代中返回任何東西。

目前的問題是，從正確的類返回的結果有時是不正確的。我想這是因爲處理器和newList也必須是本地的？如果是，我該如何解決這個問題？如果不是我哪裏出錯了？

而且要記住，使用普通的foreach工作得很好

這裏是我的代碼：

Parallel.ForEach(ofd.FileNames, 
     (file) => 
     { 
      Image exam = Image.FromFile(file); 
      var cvImage = new Image<Bgr, byte>((Bitmap)exam); 
      processor = processorMain; 
      processor.ProcessImage(cvImage); 
      List<Point> newList = new List<Point>(); 
      newList = processor.getList(); 
      correct.correct(cvImage, answerKey, nOptions); 
     }); 

Answer 1

實際問題/問題的評論指出：

我每一次迭代都是獨立的，我不需要從一次迭代中返回任何東西。

在這種情況下，你不希望你的Image是線程本地的，你只需要它們在本地。因此，解決辦法是簡化：

Parallel.ForEach(ofd.FileNames, 
    (file) => 
    { 
     var cvImage = new Image<Bgr, byte>((Bitmap)exam); 
     processor = processorMain; 
     processor.ProcessImage(cvImage); 
     List<Point> newList = new List<Point>(); 
     newList = processor.getList(); 
     correct.correct(newList, cvImage, answerKey, nOptions); 
    }); 

但你的代碼是不是真的用file任何地方，所以這只是一個粗略的猜測。它現在還不正確。

而另一方面，processorMain，answerKey和nOptions的使用是潛在的問題。

---

，還有一些人的意見後，你需要的是：

IList<Image> result = ofd.FileNames 
     .AsParallel() 
     .Select((file) => 
{ 
    Image exam = Image.FromFile(file); 
    ... 
    return exam; 
}).ToList(); 

Answer 2

你的問題很可能在這行代碼：

 processor = processorMain; 
     processor.ProcessImage(cvImage); 
     List<Point> newList = processor.getList(); // don't make a new list and then just throw it away by overwriting it. 

看起來processor正在處理您的圖像並存儲一些結果，您稍後可以訪問processor.getList()。但是如果多個線程並行運行，第二個線程可能在第一個線程調用它之後但在第一個線程到達processor.getList()之前調用ProcessImage。這意味着第一個線程將從第二個線程獲取列表結果。

最簡單的解決辦法是在每次迭代中創建一個處理器：

 processor = new MyProcessorType(); 
     processor.ProcessImage(cvImage); 
     List<Point> newList = new List<Point>(); 
     newList = processor.getList(); 

這是依賴於假設處理器不依賴於任何靜態數據。

另一種選擇是修改處理器，以便點列表存儲在線程本地存儲中。