加速通過並行.for

Question

需要從oracle下載大量數據（每日），然後刪除sql server上的數據（重新運行的情況下），然後將數據粘貼到帶有sqlbulk副本的sql server中。非平行版本：

 for (int i = 0; i < curves.Rows.Count; i++) 
     { 
       //download data from oracle 
       var data = GetCurve(connectString, impdate, curves.Rows[i]); 
       //delete old data in sql server 
       DeleteSQL(DateTime.Now, curves.Rows[i]); 
       //write to sql server with sqlbulk.copy 
       writeCurve(data, "dbo.t_Curves"); 
} 

我想加快使用parallel for，但顯然這些步驟是相互依賴的。這是我想出來的（我以前從未使用任務工廠）：

Parallel.For(0, curves.Rows.Count, i => 
     { 
       var taskLoad = Task.Factory.StartNew(() => GetCurve(connectString, impdate, curves.Rows[i])); 
       var taskDelete = Task.Factory.StartNew(() => DeleteSQL(impdate, curves.Rows[i])); 
       taskDelete.Wait(); 
       taskLoad.Wait(); 
       var taskWrite = Task.Factory.StartNew(() => writeCurve(taskLoad.Result, "dbo.t_Curves")); 
    }); 

這大概減半了時間。我可以期待的時間減半了嗎？這是線程的正確使用嗎？這是我能做的嗎？我可以加入任何進一步的加速嗎？

UPDATE

只是爲了信息，曲線是定義一個DataTable和我不是寫或逐行讀取任何行。

或者我應該寫這樣的：

Parallel.For(0, curves.Rows.Count, i => 
     { 
       var taskLoad = Task.Factory.StartNew(() => GetCurve(connectString, impdate, curves.Rows[i])); 
       var taskDelete = Task.Factory.StartNew(() => DeleteSQL(impdate, curves.Rows[i])); 
       var res1 = await taskDelete; 
       var res2 = await taskLoad; 
       writeCurve(res2, "dbo.t_Curves"); 
    }); 

Answer 1

問：這是正確使用線程的？

答：是的，你正在做兩個單獨的任務昂貴的工作，然後等待他們完成之後繼續。對@ jugarr肯定+1，指出你不需要另一個任務來完成最後一點工作

問：這是你所能做的嗎？

*大概沒有，從你在做什麼聲音，你是

• 在MSSQL
獲取單行（甲骨文）
• 刪除單個行（如果它已經存在）
• 添加單列回MSSQL

一些建議：

• 批註起來，不要一次只使用一行。
• 簡介最慢的部分是檢索數據，刪除它還是插入？它可能是這樣的：
  • 使用單行，啓動 新連接的開銷可能很大。這可能是因爲想嘗試刪除，因爲參照完整性

你得到什麼吞吐速率的數據時，檢索數據

缺少索引時

缺失索引？多少MB/s？每條曲線是1MB還是1GB？