パラレルforeachのタイムアウト優雅に近いすべてのワーカースレッド

Question

私は次のような構成があります：最初のオープンデータベース接続に使用

  Parallel.ForEach(Program.config.Root.Elements("databases"), el => 
      { 
       try 
       {     
       DBConnection.OpenConnection(el.Attribute("database_alias").Value); 
       } 
       catch (Exception exc) 
       { 
        WriteLog(10, exc); 
       } 
      }); 

この構造を。しかし、第三者コンポーネントの反復のために、アプリケーション全体でハングすることがあります。そこで、私たちは補完を改善し、新しいものを手に入れます：

  Parallel.ForEach(Program.config.Root.Elements("databases"), el => 
      { 
       try 
       { 
        System.Threading.Thread t = new System.Threading.Thread(new System.Threading.ParameterizedThreadStart(DBConnection.OpenConnection)); 
        t.Start(el.Attribute("database_alias").Value); 

        // Handling 50 seconds timeout 
        if (!t.Join(50000)) 
        { 
         t.Abort(); 
         // Force closing because connection is hanging with "connecting" state 
         Program.myConnections[el.Attribute("database_alias").Value].Conn.Close();              
        }       
       } 
       catch (Exception exc) 
       { 
        WriteLog(10, exc); 
       } 
      }); 

しかし、今でも私たちは時間内に生きているスレッドを持っています。私は彼らがタスクマネージャーの金額を数えるのを見ることができます。誰もそれをどう管理するか知っていますか？ ありがとうございます！

Answer 1

Thread.Abortが機能していない場合、スレッドはおそらくネイティブコードでハングしている可能性があります。実際には、スレッドを中止するのは通常と非常に悪い考えです。とにかくです。 AppDomainをアンロードしている場合を除きます。

これは私が次に試すことです：一時的なAppDomainでスレッドを開始し、50秒のテスト後にアンロードします。

これが機能しない場合は、一時的なプロセスに移動する必要があります。

Answer 2

あなたのコードは、あなたがそれをリファクタリングすることができますので、もしご参照ください、理解することはやや困難である：

System.Threading.Thread t = new System.Threading.Thread(new System.Threading.ParameterizedThreadStart(DBConnection.OpenConnection)); 
t.Start(el.Attribute("database_alias").Value); 

// Handling 50 seconds timeout 
if (!t.Join(50000)) 
{ 
    t.Abort(); 
    // Force closing because connection is hanging with "connecting" state 
    Program.myConnections[el.Attribute("database_alias").Value].Conn.Close();              
} 

あなたの代わりにこれを行うことができるかどうか見てみてください。

Thread t = new Thread(()=> 
{ 
    try 
    { 
     // I'm not sure what the correct call is for OpenConnection, but the code below 
     // seems appropriate. If it's not right, then do it the right way 
     DBConnection.OpenConnection(el.Attribute("database_alias").Value); 
    } 
    catch(ThreadInterruptedException tie) 
    { 
     // Eat the exception or do something else (i.e. cleanup or whatever) 
    } 
}); 
t.IsBackground = true; 
t.Start(); 

// Handling 50 seconds timeout 
if (!t.Join(50000)) 
{ 
    // Interrupt the exception instead of aborting it (this should get you out of blocking states) 
    t.Interrupt(); 

    // Force closing because connection is hanging with "connecting" state 
    Program.myConnections[el.Attribute("database_alias").Value].Conn.Close();              
}