WPF工作者線程需要通過消費者通知暫停

Question

嗨，我有一個生產者 - 消費者模式。 WPF UI對於長時間運行的工作線程來說是一種輔助工具，它正在偵聽數據包並使任務進入隊列。在實踐中，所有消息都被出隊，然後UI消費者進行處理。

我遇到的問題是我有一個UIcontroller類負責所有的WPF GUI組件。它打開一個新窗口，顯示每個出隊任務並保存一個線程安全的引用窗口集合。

我通過Despatcher.BeginInvoke發出信號。那裏沒有驚喜。

我遇到的問題是，如果UIController類成功打開一個配置數量的窗口，我想暫停/逐字停止我的工作線程。打開的窗口數量有限制。一旦打開的窗口數量減少回到範圍內，我將恢復對隊列的處理。我試着把這個窗口集合保存在這個類中，並通過調用將它傳遞給UI，在這裏通過引用更新它，但Begin Invoke是異步的，並且計數在工作線程的循環中沒有及時更新。

我可以在UIcontroller類中測試打開的窗口的否，忽略甚至重新從那裏執行任務 - 基本上不採取任何行動。但我想要一個更清潔的解決方案。

我可以做一些乾淨的回調嗎？

public void Work() 
    { 

     while (true) 
     { 

      Log.Instance.Info("****In worker THREAD " + _worker.Name); 

      while (_controller.IncomingMessages.Count > 0 && [--test for no of windows open on GU thread somehow - I did try holding a reference to the collection in this class--]) 
      { 
       try 
       { 
        Log.Instance.Info("****In Notification worker THREAD and messages to process " + _worker.Name); 

        Messages.AlertMessage task = null; 
        lock (_locker) 
        { 

         if (_controller.IncomingMessages.Count > 0 && ToasterPopUps.Count < 5) 
         { 
          task = _controller.IncomingMessages.Dequeue(); 
          if (task == null) 
          { 
           return; 
          } 
         } 

         if (task != null) 
         { 
          Log.Instance.Info("Dequeing: " + task + " " + task.ID + " from Notification thread"); 

       _UIthread.BeginInvoke(DispatcherPriority.Background, new JoinUIThread(DespatchUIThread), task, _UIthread); 
         } 
        } 

       } 
       catch (Exception err) 
       { 
        Log.Instance.Critical(string.Format("Unexpected Error in PollPopUp Thread Queue {0} ", err)); 
       } 

      } 

      Log.Instance.Info("No more Notification tasks - wait for a signal"); 

      _wh.WaitOne(); 

     } 

    } 

    public void DespatchUIThread(Messages.AlertMessage task, System.Windows.Threading.Dispatcher dispatcherThread) 
    { 
     try 
     { 
      _controller.CreateWindow(task, dispatcherThread); 
     } 
     catch (Exception err) 
     { 
      Log.Instance.Critical("Critical error " + err); 
     } 
    } 

Answer 1

如果我理解你，你希望生產者線程等待，而UI窗口的數量是在一定的閾值。我會使用生產者和使用者共享的信號量，並初始化爲最大窗口數來完成此行爲。

const int MaxWindowCount = 5; 
Sempahore semaphore = new Semaphore(0, MaxWindowCount); 

每個入隊之前，你叫

semaphore.WaitOne(); 

一旦每個任務完成，它的窗口關閉，呼叫

semaphore.Release(); 

一旦MaxWindowCount項目已排隊，你的生產者將等待其下一個電話WaitOne（）並將等到發佈（）被調用。

嗯，這可能不會達到你想要的，因爲它限制隊列中MaxWindowCount的數量，不一定是打開窗口的數量。它假設排隊中的每個項目都有一個打開的窗口，在您的情況下可能不是這樣。

如果這是一個無效的假設，您可能有一個線程負責從隊列中拉出項目。這個線程將負責調用WaitOne（），同時將項目交給UIController。 UIController仍然負責呼叫版本（）。實際上，你會有兩個生產者 - 消費者隊列。一個用於任務的無限隊列和一個用於Windows的有界隊列。

--Added 2010年5月21日 -

另一種選擇可能是有通話與CreateWindow採取一個回調參數，告訴控制器打開的窗口數量。

使用以下委託作爲CreateWindow的參數，可以保持Worker中的打開窗口的計數，並在達到最大值時相應地執行相應操作。

public delegate void CreateWindowCallback(int numOpenWindows); 

你可能會保持你的工作人員打開窗戶的計數，你需要讓工作人員知道最大窗口數。或者，您可以在Controller類中保留CanOpenNewWindows布爾值。

呼叫前_UIthread.BeginInvoke工人可以檢查當前窗口計數（或CanOpenNewWindows財產），如果它不應該打開一個新的窗口，調用了WaitOne（）。您仍然需要知道什麼時候關閉窗口，以釋放/通知工作人員繼續。

在窗口創建失敗或控制器不需要顯示窗口的情況下，您可以讓工作人員知道打開的窗口計數沒有增加。這確實假定_controller知道是否創建了一個窗口。

- 另一種思考 -

它可能會保留所有的窗口創建邏輯在你的UIController。 UIController需要知道UIThread並將CreateWindow調用修改爲只接受任務。

對的調用CreateWindow（任務）將調用BeginInvoke，如果有少於最大窗口打開。否則，它會調用WaitOne（）並等待其中一個窗口發出信號表明它們已關閉。我們可以在這裏使用信號量，在每次成功創建窗口後調用WaitOne（）。每個窗口在關閉時都會負責調用Release（）。

這樣，當工作人員直接調用CreateWindow時，它會在達到最大窗口計數時阻塞，並且永遠不需要知道最大窗口數或關於UI的其他更多信息。