C#綜合揭秘——細(xì)說(shuō)事務(wù)(下)

 1 using (TransactionScope scope1 = new TransactionScope())            
 2 {
 3        ..............               
 4        using (TransactionScope scope2=new TransactionScope(TransactionScopeOption.RequiresNew))
 5        {
 6               ..............
 7               scope2.Complete();   //只完成嵌套式的內(nèi)部事務(wù)，但事務(wù)并未正式提交
 8        }
 9        scope1.Complete();  //代表完成所有事務(wù)，事務(wù)正式提交
10 }

 1 namespace DAL
 2 {     
 3      public class OrderDAL
 4      {
 5          public void UpdateOrder(Order order)
 6          {
 7              using (TransactionScope scope = new TransactionScope())
 8              {
 9                   ......         
10                   scope.Complete();
11              }
12          }
13      }
14  
15      public class OrderItemDAL
16      {
17          public void AddOrderItem(OrderItem orderItem)
18          {
19              using (TransactionScope scope = new TransactionScope())
20              {
21                  ......
22                  scope.Complete();
23              }
24          }
25      }
26  }
27 
28 namespace BLL
29 {
30      public class OrderManager
31      {
32          public void AddOrderItem(OrderItem item)
33          {
34              using (TransactionScope scope = new TransactionScope())
35              {
36                  OrderItemDAL orderItemDAL=new OrderItemDAL();
37                  orderItemDAL.AddOrderItem(item);
38                  OrderDAL orderDAL=new OrderDAL();
39                  ........
40                  orderDAL.UpdateOrder(order);
41                  scope.Complete();
42              }
43          }
44      }
45 }

 1      class Program
 2      {
 3          static void Main(string[] args)
 4          {
 5              Method();
 6              Console.ReadKey();
 7          }
 8  
 9          static void Method()
10          {
11              using (TransactionScope scope = new TransactionScope())
12              {
13                  ShowMessage("Main Thread");
14  
15                  //獲取一個(gè)依賴(lài)事務(wù)，把依賴(lài)事務(wù)作為回調(diào)參數(shù)傳到回調(diào)函數(shù)中
16                  DependentTransaction dependentTransaction=
17                     Transaction.Current.DependentClone(DependentCloneOption.BlockCommitUntilComplete);
18                  ThreadPool.QueueUserWorkItem(new WaitCallback(AsyncThread), dependentTransaction);
19                  ........
20                  scope.Complete(); //完成主線(xiàn)程事務(wù)，在依賴(lài)事務(wù)完成前，事務(wù)提交將處于阻塞狀態(tài)
21              }
22          }
23  
24          static void AsyncThread(object transaction)
25          {
26              //獲取依賴(lài)事務(wù)，利用TransactionScope（Transaction）構(gòu)造函數(shù)生成隱式事務(wù)
27              DependentTransaction dependentTransaction = (DependentTransaction)transaction;
28              using (TransactionScope scope = new TransactionScope(dependentTransaction))
29              {
30                  ShowMessage("AsyncThread");
31                  ..........
32                  scope.Complete();  //完成異步事務(wù)
33              }
34              //完成依賴(lài)事務(wù)
35              dependentTransaction.Complete();
36          }
37  
38          static void ShowMessage(string data)
39          {
40              if (Transaction.Current != null)
41              {
42                  Transaction transaction = Transaction.Current;
43                  string info = string.Format("{0}:{1}\nTransaction:\n  DistributedIndentifier:{2} \n  LocalIndentifier:{3}\n",
44                      data,Thread.CurrentThread.ManagedThreadId.ToString(),
45                      transaction.TransactionInformation.DistributedIdentifier,
46                      transaction.TransactionInformation.LocalIdentifier);
47                  Console.WriteLine(info);
48              }
49          }
50      }