多線程事務異常終止與實體框架

Question

我有一個多線程事務和實體框架的問題。我有一個線程，它在事務中運行，我想在同一個事務中有更多的工作線程工作。下面的代碼說明了情況（在EF上下文中有一個虛擬實體，代碼基本上產生了5個線程，我想在每個線程中插入一些實體，並在主線程的末尾，我想繼續使用DB，但是以保持整個過程隔離在一個交易）：

using(var scope = new TransactionScope()) 
{ 
    int cnt = 5; 
    ManualResetEvent[] evt = new ManualResetEvent[cnt]; 

    for(int i = 0; i < cnt; i++) 
    { 
     var sink = new ManualResetEvent(false); 
     evt[i] = sink; 

     var tr = Transaction.Current.DependentClone(
      DependentCloneOption.BlockCommitUntilComplete); 

     Action run =() => 
     { 
      using (var scope2 = new TransactionScope(tr)) 
      { 
       using (var mc = new ModelContainer()) 
       { 
        mc.EntitySet.Add(new Entity() 
        { 
         MyProp = "test" 
        }); 
        mc.SaveChanges(); 
       } 
      } 

      sink.Set(); 
     }; 

     ThreadPool.QueueUserWorkItem(r => run()); 
    } 

    ManualResetEvent.WaitAll(evt); 

    using (var mc = new ModelContainer()) 
    { 
     Console.WriteLine(mc.EntitySet.Count()); 
    } 
    Console.ReadKey(); 
} 

問題是，該異常引發mc.SaveChanges（）;.內部異常是TransactionException：「該操作對於事務狀態無效。」似乎在某個時候，交易被中止。我認爲這是第一次線程調用SaveChanges（）後，但林不知道。任何想法爲什麼交易中止？

Answer 1

我發現了什麼問題發生在這裏。根據this article，我發現在一個事務中同時處理兩個MSSQL服務器連接是不可能的。我還發現，我沒有正確處理以前的代碼中的依賴事務。我的工作圖示碼如下：

class Context 
    { 
     public ManualResetEvent sink; 
     public DependentTransaction transaction; 
    } 

    static object syncRoot = new object(); 

    static void Main(string[] args) 
    { 
     using (var scope = new TransactionScope()) 
     { 
      int cnt = 5; 
      ManualResetEvent[] evt = new ManualResetEvent[cnt]; 

      for (int i = 0; i < cnt; i++) 
      { 
       var sink = new ManualResetEvent(false); 
       evt[i] = sink; 

       var context = new Context() 
       { 
        // clone transaction 
        transaction = Transaction.Current.DependentClone(DependentCloneOption.BlockCommitUntilComplete), 
        sink = sink 
       }; 

       ThreadPool.QueueUserWorkItem(new WaitCallback(Run), context); 
      } 

      // wait for all threads to finish 
      ManualResetEvent.WaitAll(evt); 

      using (var mc = new ModelContainer()) 
      { 
       // check database content 
       Console.WriteLine(mc.EntitySet.Count()); 
      } 

      // after test is done, the transaction is rolled back and the database state is untouched 
      Console.ReadKey(); 
     } 
    } 

    static void Run(object state) 
    { 
     var context = state as Context; 

     // set ambient transaction 
     Transaction oldTran = Transaction.Current; 
     Transaction.Current = context.transaction; 

     using (var mc = new ModelContainer()) 
     { 
      mc.EntitySet.Add(new Entity() 
      { 
       MyProp = "test" 
      }); 

      // synchronize database access 
      lock (syncRoot) 
      { 
       mc.SaveChanges(); 
      } 
     } 

     // release dependent transaction 
     context.transaction.Complete();    
     context.transaction.Dispose(); 

     Transaction.Current = oldTran; 

     context.sink.Set();    
    } 
} 

這可能不是編寫多線程經營業務層的非常好的方式，但這種共享事務處理方法是WERY在我的情況下，測試非常有用。唯一需要做這項工作的修改是覆蓋Db上下文，並在測試運行中同步保存方法。

Answer 2

一個SqlConnection不是線程安全的（和EF ObjectContext的/ DbContect不是線程安全的爲好），所以這個時候你同步訪問上下文和連接纔有效。你想出一個模型，並行處理CPU密集型的東西，並在所有線程完成後在一個線程中寫入所有更改。