多個生產者，多個消費者和商店問題

我有一個場景，其中多個生產者在網絡中的不同機器上運行。這些是Singleton WCF服務，它將產品（輸出）排隊在Central Store中，這也是Singleton WCF服務。多個生產者，多個消費者和商店問題

有些消費者通過JSON請求調用Central Store來從Central Store出廠產品。產品通過解決某些優先級限制來交付。生產者在1萬分鍾內以非常高的速度生產產品，目的是以同樣的速度向消費者提供服務，而不是讓他們等待。

只要我有3-4個生產者和多達10個消費者，一切正常。但是，當我增加生產者和消費者的一切凍結。

我使用的是TimedLock這是Monitor.TryEnter的包裝。我嘗試了所有類型的同步技術，如ReaderWriterLockSlim和Web上的其他帖子，但結果相同。我避免了ReaderWriterLockSlim，因爲我有大量的寫入而不是讀取。

由於我無法控制消費者和生產者線程，這些線程由WCF產生，因爲他們訪問的是Singleton Store。我無法實施網上提供的產品/消費者樣品。以下是數據存儲的示例代碼。

public class Store:IEnumerable<Product> 
{ 
    private List<Product> _Products; 
    private object _MonitorLock; 

    public Store() 
    { 
     _Products = new List<Product>(); 
     _MonitorLock = new object(); 
    } 
    public void Add(Product Product) 
    { 
     lock (_MonitorLock) 
     { 
      _Products.Add(Product); 
     } 
    } 

    public void Remove(Product Product) 
    { 
     lock (_MonitorLock) 
     { 
      _Products.Remove(Product); 
     } 
    } 

    public int Count 
    { 
     get 
     { 
      lock (_MonitorLock) 
      { 
       return _Products.Count; 
      } 
     } 
    } 

    public IEnumerator<Product> GetEnumerator() 
    { 
     List<Product> ProductsCopy; 

     lock (_MonitorLock) 
     { 
      ProductsCopy = new List<Product>(_Products); 
     } 

     foreach (Product oEntry in ProductsCopy) 
      yield return oEntry; 
    } 


    public Product GetHighestPriorityProduct() 
    { 
     Product oProduct; 
     lock (_MonitorLock) 
     { 
      //Some Logic to Resolve the Priority 

      _Products.Remove(oProduct); 
     } 
     return oProduct; 
    } 


    #region IEnumerable Members 

    System.Collections.IEnumerator System.Collections.IEnumerable.GetEnumerator() 
    { 
     return GetEnumerator(); 
    } 

    #endregion 
}

來源

2009-09-17 Protean

我不知道這是否會是任何幫助都，但在這種環境下我會研究是否使用的是Windows工作流（即關閉的框架的一部分移交調度問題）會幫助。 WF運行時可以提供一系列要處理的項目;並將爲您在單個操作系統線程的單個工作流程內進行綠色線程活動（針對更多操作系統線程，只需添加更多工作流程）。

來源

2009-09-17 07:18:26

你是說它因_MonitorLock上的死鎖而凍結？您是否使用ThreadPool線程，如果是這樣，凍結是否發生在線程數達到ThreadPool限制的時間？

您是否做過各式各樣的生產者和消費者組合，以查看導致鎖定的原因？

您是否已將日誌記錄添加到您的代碼中以查看它是否被凍結，因爲需要花費很長時間來獲取下一個最高優先級的對象？如果是這種情況，那麼實施優先隊列會有所幫助（http://www.vcskicks.com/priority-queue.php）。

來源

2009-09-18 23:21:56

在深入研究問題後，我發現應用程序凍結時僅增加了消費者數量。如果我增加生產者但保持消費者低，它不會凍結。正如您已經指出的那樣，凍結可能是因爲優先解析需要長時間，並且lock（）在整個時間內都會被獲取。我會嘗試優先隊列併發布反饋。感謝您的建議。 – Protean 2009-09-20 10:50:33

多個生產者，多個消費者和商店問題

回答

相關問題