線程最好的實現

Question

我有一個應用程序，我有很多「搜索」在同一時間運行（在搜索需要1 - 10秒才能完成，這取決於有多少結果是可用的）問題是，搜索時的延遲越來越大（我認爲，因爲25最大線程）我使用Backgroundworker類Atm。於是我查閱了一些其他的實現：

簡單的例子：

static void Main() 
{ 

    for (int i = 0; i < 500; i++) 
    { 
     try 
     { 
      new Thread(new ParameterizedThreadStart(doWork)).Start(i); 
     } 
     catch { } 
    } 
    Console.ReadLine(); 
} 
static void doWork(object i) 
{ 
    Console.WriteLine(i + ": started"); 
    Thread.Sleep(1000); 
    Console.WriteLine(i + " done"); 
    Thread.CurrentThread.Abort(); 
} 

，但我得到的是我中止線程中的異常（至極讓我擔心） 所以，我想蒙山線程池：

static void Main() 
{ 

    for (int i = 0; i < 500; i++) 
    { 
     ThreadPool.QueueUserWorkItem(new WaitCallback(doWork), i); 
    } 
    Console.ReadLine(); 
} 
static void doWork(object i) 
{ 
    Console.WriteLine(i + ": started"); 
    Thread.Sleep(1000); 
    Console.WriteLine(i + " done"); 
} 

但是這變得味道很慢...

我仍然在尋找最佳實施，任何人都可以幫助我嗎？

編輯：DoWork的方法建立網絡連接（並等待它完成）這是一個API，所以我不能做異步

Answer 1

線程池嘗試最小化創建的線程數，而不是爲排隊的任務創建新線程，而是等待池中的其他線程被釋放。這是有原因的 - 太多的線程會妨礙性能。但是，您可以在發生此限制之前覆蓋要創建的最小線程數。

這裏是你的原代碼修正，使其工作速度快：

static void Main() 
{ 
    int minWorker, minIOC; 
    ThreadPool.GetMinThreads(out minWorker, out minIOC); 
    ThreadPool.SetMinThreads(50, minIOC); 
    for (int i = 0; i < 500; i++) 
    { 
     ThreadPool.QueueUserWorkItem(new WaitCallback(doWork), i); 
    } 
    Console.ReadLine(); 
} 

static void doWork(object i) 
{ 
    Console.WriteLine(i + ": started"); 
    Thread.Sleep(1000); 
    Console.WriteLine(i + " done"); 
} 

Answer 2

不要使用Thread.Abort。這是一個相當暴力的結局，只是想要優雅地結束一個糟糕的工作威脅。您可以讓原始的doWork方法結束，並且線程將被釋放。

和關於你的第二個解決方案 - 你在第二，這是很多超過線程池可以同時運行排隊500個線程。它需要更多時間，因爲它們一個接一個地運行。

另一種選擇，在.NET 4.0中，在System.Threading.Tasks任務庫，這是一個聰明的基於線程池的解決方案可以考慮。

但要回到原來的問題 - 究竟是什麼，你的「延遲變長」使用BackgroundWorkers時，是什麼意思？你的意思是說，當有多個搜索進行時，每個搜索需要更長的時間（接近10秒）？如果是這樣，我會嘗試尋找其他地方的瓶頸。什麼是「搜索」？你在訪問數據庫嗎？網絡連接？也許你鎖定了導致瓶頸的應用程序部分。

Answer 3

1）如果你打電話中止，你會得到一個ThreadAbortException：Thread.Abort

2）¿500個線程？ （除非你正在使用圖形處理器）

Answer 4

如果搜索是CPU綁定，我會使用Parallel.For或並行linq，手動指定MaxDegreeOfParallelism。在這種情況下，通常虛擬內核的數量是最佳線程數。

如果搜索上的東西外等待（開往例如IO，等待在網絡上的響應，...），我會考慮非阻塞的API，所以你不需要每次搜索的線程。

Answer 5

嘗試這種解決方案：

static void Main(string[] args) 
{ 
    for (int i = 0; i < 100; i++) 
    { 
     Task t = new Task(doWork, i); 
     t.Start(); 
    } 
    Console.ReadLine(); 
} 

static void doWork(object i) 
{ 
    Console.WriteLine(i + ": started"); 
    Thread.SpinWait(20000000); // It depends on what doWork actually does whether SpinWait or Sleep is the most appropriate test 
    //Thread.Sleep(1000); 
    Console.WriteLine(i + " done"); 
} 

隨着任務你有更好的方法來控制你的工作項目，並擴大那些能夠提高性能的選項。任務的默認TaskScheduler使用ThreadPool排隊工作項目。 （請閱讀本答案的底部以獲取有關任務的更多信息。）

所以，要回答這個問題，我們需要知道doWork實際上做了什麼:-)但總的來說Task將是一個不錯的選擇和一個很好的抽象。

並行foreach

如果使用循環產卵的工作，你正在做data parallelism然後並行的foreach可以做的工作：

Parallel.For(0, 500, i => doWork(i)); 

鏈接：

• http://msdn.microsoft.com/en-us/library/dd537609.aspx
• http://msdn.microsoft.com/en-us/library/dd460717.aspx

要評論從花錢

http://msdn.microsoft.com/en-us/library/dd537609.aspx

任務提供兩個主要好處：

1）更高效，更可擴展的系統資源的使用。

在幕後，任務排隊等待ThreadPool，這已被 增強，算法（如爬山）確定和 調整爲最大化吞吐量的線程數。這使得 任務相對輕量級，並且您可以創建其中的許多任務來啓用細粒度並行。爲了補充這一點，採用廣爲人知的工作竊取算法來提供負載平衡。

2）更多的線程或工作項目可能的編程控制。

任務和圍繞它們構建的框架提供了一套豐富的API集合，支持等待，取消，繼續，強大的異常 處理，詳細狀態，自定義調度等。

更新答案

嗯，這是不幸的是一個壞的API，因爲它不會讓你以異步方式做到這一點。它可能會變慢，因爲你同時啓動了很多連接（或者你開始太少）。與MaxDegreeOfParallelism值

var jobs = new[] { 1, 2, 3}; 
var options = new ParallelOptions { MaxDegreeOfParallelism = 3 }; 
Parallel.ForEach(jobs, options, i => doWork(i)); 

與實驗：

試試這個。

Answer 6

任何涉及爲要處理的ThreadPool排隊500個項目的任何操作都將無法以最佳吞吐量運行。 ThreadPool通常很不情願旋轉額外的線程，因爲這種用法不是設計者所期望的。

這聽起來像你是IO綁定，在這種情況下，你可以異步執行IO和服務一切與線程很少。但是，如果不瞭解更多關於工作量的信息，這是一個猜謎遊戲。