使用並行線程時，應用程序卡住

Question

我正在努力改進數據庫同步應用程序，該應用程序需要在當時處理數百萬條記錄。我將採用SqlBulkCopy操作，然後在數據庫上使用MERGE將臨時表與當前表合併。但在此之前，我創建了幾個將添加到數據庫中的表。當我使用常規循環時，它工作正常，但是當我創建Parallel.ForEach循環時，它處理大約100條記錄，然後掛起。沒有錯誤，沒有什麼......我認爲它正在達到某種閾值，但不知道如何處理它。當我選擇2個並行線程時，它可以很好地工作，但它會陷入大於2個線程而沒有任何錯誤。

DataTable PRODUCT = new DataTable(); 

ParallelOptions parOptions = new ParallelOptions(); 
parOptions.MaxDegreeOfParallelism = 5; //use max (5) threads that are allowed. 
Parallel.ForEach(dtPs.AsEnumerable(), parOptions, dtPs_row => 
{ 
    try 
    { 
     //some declarations 
     DataRow newProductRow = PRODUCT.NewRow(); 
     newProductRow.SetField("ID", mId); 
     newProductRow.SetField("NAME", name); 
     PRODUCT.Rows.Add(newProductRow); 
    } 
} 

Answer 1

這裏是您的代碼的示例：

DataTable PRODUCT = new DataTable(); 
    Object lockobj = new Object(); 


    ParallelOptions parOptions = new ParallelOptions(); 
    parOptions.MaxDegreeOfParallelism = 5; //use max (5) threads that are allowed. 
    Parallel.ForEach(dtPs.AsEnumerable(), parOptions, dtPs_row => 
    { 
     try 
     { 
      //some declarations 
      lock(lockobj) 
      { 
       DataRow newProductRow = PRODUCT.NewRow(); 
       newProductRow.SetField("ID", mId); 
       newProductRow.SetField("NAME", name); 
       PRODUCT.Rows.Add(newProductRow); 
      } 
     } 
    } 

假設Object lockobj = new Object();是在類級的方法之外。