Thread.Sleep（Timespan.Zero）可以在這種情況下使用嗎？

Question

我正在寫一個程序，它從文件中讀取數據包，並將每個數據包分配到指定的管道進行處理。每個管道對象都有一個阻塞隊列和一個過濾器類。可以同時運行多條這樣的管道。

阻塞隊列只是在輸入端收集數據包，直到它達到最大容量，此時它會阻塞隊列方法，直到過濾器出隊的某些數據包。阻塞隊列是一個簡單的類，它使用Monitor.Wait()和Monitor.Pulse()進行同步。

每個過濾器都有一個Process()方法在其專用線程上執行。它看起來是這樣的：

public void Process() 
{ 
    while (!done) 
    { 
     var packet = sourceQueue.Dequeue(); 

     // Perform some filtering operation on packet here 

     targetQueue.Enqueue(sourceQueue); 

     // Let other threads do some work 
     Thread.Sleep(Timespan.Zero); 
    } 
} 

什麼以這種方式使用Thread.Sleep()方法的可能的陷阱？

的MSDN documentation規定，使用Thread.Sleep(Timespan.Zero)「表示該線程應暫停允許其他等待線程來執行，」這是我想要的。

但是有博客條目like this one基本上說使用Thread.Sleep是邪惡的。爲什麼？這是一個很好的使用Thread.Sleep，還是有更好的方法？

Answer 1

真正的程序不睡覺（）。

您的建議Sleep(0)還有一個問題，只允許具有相同優先級的線程運行。一般認爲Sleep(1)更安全一些。見Joe Duffy。

但是在任何情況下，您的分辨率都是20ms，這可能會太長。

你所說的循環做了一點工作，然後引發一個上下文切換，非常浪費。

充分利用時間段會更好，因此請繼續工作，直到隊列阻止您。阻塞比睡眠好。

Answer 2

只要性能不重要，你會沒事的。

使用Thread.Sleep唯一不利的方面是，您不知道多久可以控制回來，因爲所有其他線程在重新獲取之前都會獲得處理時間。只要你不在乎在控制恢復之前20ms還是100ms，你就不會遇到任何問題。

Answer 3

如果您使用.NET 4，我會親自使用Thread.Yield這樣可以很清楚你想達到什麼樣的......但除此之外，你的睡眠看起來應該是好給我。 ..（取決於0或1的選擇，如其他地方所述），但你確定它確實有必要嗎？你是否執行過任何分析來檢查它是否真的有幫助？讓這個線程完成時間片的缺點是什麼？

它看起來像你不依靠睡正確性這是彼得裏奇的博客文章的主旨，據我所知......這意味着它必須是出於性能原因。與的任何爲了表現一樣，你應該真正衡量有無這個表現，看看它是否真的值得。如有疑問，請使用簡單的代碼:)

Answer 4

如果有工作要做，那麼不要這樣做？除非你的系統有進一步的限制，否則按照John的建議，過濾所有的輸入，直到排隊是空的似乎是合理的。其他的管道線程也會做很多事情，所以他們都應該完成他們的工作。

如果您的問題是，你的「過濾操作」所做的工作是非常小的，所以你要處理他們的塊，以減輕過度的上下文切換梅比你既可以：

1）使用由較少的線程將所需的「過濾操作」傳遞給數據包，即。作爲分組的一種方法。然後較少的線程可以執行更廣泛的作業，因此可以增加每個線程的負載並減少上下文切換/數據包。如果任何線程可以執行任何過濾操作，那將是有用的，但我意識到這並非總是可行的。

2）將大量數據包對象加載到列表/隊列/堆棧上，並將此構造推送到線程隊列中。

另一個考慮幾點：

謹防「監視脈衝」和「事件信號」生產者 - 消費者隊列。我曾經看到過許多有嚴重缺陷的嘗試，特別是有多個生產者和多個CPU。消費時出現問題，因爲檢查隊列爲空以及等待監視器/事件的行爲不是一次原子操作。我還沒有相信，在一般情況下，這樣一個隊列可以做到可靠工作。如果只有一個生產者/消費者，這可能會好起來，所以你可能會好起來，但如果你的應用程序加載時出現奇怪的事情，請記住這一點。 '計算機科學117'生產者 - 消費者隊列使用信號量來生產者/消費者等待並自動計數隊列條目。您的隊列條目是需要應用「訪問控制」的「資源池」，即。正是MSDN所說的信號量所提供的。

負載管理。你正在使用有界隊列，這很好。另一種可能提供更好整體性能或者更糟糕的可能性（再次 - 根據應用程序的細節，這個建議可能有用或不可用）是通過創建系統來限制系統中可用數據包的總數它們在啓動時就是一個池（池可能是另一個PC隊列，所有的數據包都被壓入）。當池變空時，這個方案會節制所有的生產者 - 他們必須等到消費者釋放「使用過的」數據包回到池中，並且不需要有限的隊列。

RGDS， 馬丁

public void Enqueue(UInt64 key, T item) 
    { 
     while (queue.Count >= MaximumSize) 
      Thread.Sleep(TimeSpan.Zero); 

     lock (queue) 
     { 
      queue.Add(key, item); 

      if (queue.Count > PeakSize) 
       PeakSize = queue.Count; 

      Monitor.Pulse(queue); 
     } 
    } 

    public T Dequeue() 
    { 
     lock (queue) 
     { 
      while (!flushed && queue.Count < MinimumSize) 
       Monitor.Wait(queue); 

      var item = queue.First(); 
      T value = item.Value; 
      queue.Remove(item.Key); 

      return value; 
     } 
    }