在foreach循環中打開線程

Question

我得到一個XML提要，並將其解析爲我的MQ服務器，然後我有一個服務來監聽MQ服務器並閱讀其所有消息。

我打開一個新的線程每次迭代中，爲了使解析更快foreach循環，原因有在MQ大約500消息（意味着有500個XML）

foreach (System.Messaging.Message m in msgs) 
{ 
    byte[] bytes = new byte[m.BodyStream.Length]; 
    m.BodyStream.Read(bytes, 0, (int)m.BodyStream.Length); 
    System.Text.ASCIIEncoding ascii = new System.Text.ASCIIEncoding(); 

    ParserClass tst = new ParserClass(ascii.GetString(bytes, 0, (int)m.BodyStream.Length)); 
    new Thread(new ThreadStart(tst.ProcessXML)).Start(); 
} 

在ParserClass我有這樣的代碼：

private static object thLockMe = new object(); 
public string xmlString { get; set; } 

public ParserClass(string xmlStringObj) 
{ 
    this.xmlString = xmlStringObj; 
} 

public void ProcessXML() 
{ 
    lock (thLockMe) 
    { 
     XDocument reader = XDocument.Parse(xmlString); 
     //Some more code... 
    } 
} 

的問題是，當我運行這個foreach循環，只有1個線程，它可以完美運行，但速度緩慢。

當我用多於一個線程運行它時，出現錯誤「未將對象引用設置爲對象的實例」。

我想我的鎖定有問題，因爲我對線程不是很有經驗。

我有點無望，希望你能幫助！

乾杯！

Answer 1

我注意到你正在運行一堆線程，它們的整個代碼被包裝在一個lock語句中。您也可以按照這種方式按順序運行這些方法，因爲您沒有獲得任何並行性。

Answer 2

既然你在你的循環的每次迭代創建一個新的ParserClass實例，還創建並啓動一個新的線程每次迭代，你並不需要在你的ParseXML方法的鎖。

你在你鎖定的對象是目前static，所以不是實例綁定，這意味着，一旦一個線程是你ParseXML方法裏面，沒有其他可以做任何事情，直到第一次完成。

您的分析器類中沒有共享線程中的任何數據（來自代碼我可以看到），因此您不需要鎖定，就可以在您的ParseXML函數中使用。

如果您使用的是線程之間共享的數據，那麼您應該有一個鎖。

如果您要使用大量線程，那麼您最好使用ThreadPool，並從池中取出一個有限的（可能爲4個），分配給他們一些工作，並將它們循環用於接下來的4個任務。

創建線程是一項昂貴的操作，需要調用OS內核，因此您不需要這樣做500次。這太昂貴了。另外，Windows中針對線程堆棧的最小預留內存爲1MB，因此線程的堆棧空間中只有500MB。

線程的最佳數量應該等於您的機器中的核心數量，但由於這對大多數用途來說並不是真實的，所以您可以做到兩倍或三倍，但是最好使用線程池，你回收線程，而不是一直在創造新的。

Answer 3

儘管這可能不會解決，而不是創建500個併發線程，你應該只使用線程池，管理線程在一個更有效的方式您的問題，：

foreach (System.Messaging.Message m in msgs) 
{ 
    byte[] bytes = new byte[m.BodyStream.Length]; 
    m.BodyStream.Read(bytes, 0, (int)m.BodyStream.Length); 
    System.Text.ASCIIEncoding ascii = new System.Text.ASCIIEncoding(); 

    ParserClass tst = new ParserClass(ascii.GetString(bytes, 0, (int)m.BodyStream.Length)); 
    ThreadPool.QueueUserWorkItem(x => tst.ProcessXML()); 
} 

，並確保他們運行儘可能同時更改ParserClass這樣你的代碼（假設你確實有資源，你的線程之間共享 - 如果你沒有任何，你不必在所有的鎖）：

private static object thLockMe = new object(); 
public string XmlString { get; set; } 

public ParserClass(string xmlString) 
{ 
    XmlString = xmlString; 
} 

public void ProcessXML() 
{ 
    XDocument reader = XDocument.Parse(xmlString); 
    // some more code which doesn't need to access the shared resource 

    lock (thLockMe) 
    { 
     // the necessary code to access the shared resource (and only that) 
    } 

    // more code 
} 

關於你的實際問題：

而不是調用OddService.InsertEvent(...)多次使用相同的參數（遠程調用和副作用的方法reeks ...），您應該調用它一次，將結果存儲在變量中，並對該變量執行所有後續操作。這樣，您還可以方便地檢查它是否不是那種有時會返回null的精確方法（同時訪問？）。

編輯：

請問，如果你把所有的呼叫，OddService.*在lock塊工作的呢？