使用 DependentTransaction 管理并发

Transaction 对象是使用 DependentClone 方法创建的。它的唯一用途就是为了确保，在某些代码段（例如辅助线程）还在对事务执行操作时，该事务不会被提交。在克隆的事务内完成了执行的操作并准备提交时，该对象可以使用 Complete 方法通知事务的创建者。这样，您可以保持数据的一致性和正确性。DependentTransaction 类还可用于管理异步任务之间的并发。在此情况中，父事务可以在其依存克隆处理自己的任务的同时继续执行任何代码。换言之，在依存克隆完成前，并不阻止父事务的执行。
创建依存克隆要创建依存事务，请调用 DependentClone 方法并将 DependentCloneOption 枚举作为参数传递。下述情况下，此参数即定义事务的行为：如果在依存克隆指示事务可提交（通过调用 Complete 方法）前，针对父事务调用了 Commit。以下是此参数的有效值：BlockCommitUntilComplete 创建一个依存事务，该事务阻止父事务的提交进程，直到父事务超时，或者直到针对所有依存事务都调用 Complete 来指示它们已完成时。这十分适合于客户端不希望在完成依存事务前就提交父事务的情况。如果父事务完成其工作的时间早于依存事务并且对该事务调用 Commit，则在可以对事务执行附加工作并且可以创建新登记的状态中阻止提交过程，直到所有依存事务都调用 Complete。只要所有这些事务都已完成其工作并调用 Complete，就开始该事务的提交过程。在另一方面，RollbackIfNotComplete 创建一个依存事务，如果在调用 Complete 前即对父事务调用 Commit，则该依存事务将自动中止。在此情况下，在依存事务中进行的所有工作在一个事务生存期内将不改变，并且没有任何机会提交哪怕是事务的一部分。在您的应用程序完成对依存事务的工作后必须只调用 Complete 方法一次；否则，将引发 InvalidOperationException。在进行此调用后，您不得尝试对该事务再进行任何其他工作，否则将引发异常。下面的代码示例说明如何通过克隆依存事务并将其传递到辅助线程，创建依存事务以管理两个并发任务。 
复制内容到剪贴板 
代码:
public class WorkerThread
{
public void DoWork(DependentTransaction dependentTransaction)
{
Thread thread = new Thread(ThreadMethod);
thread.Start(dependentTransaction); 
}public void ThreadMethod(object transaction) 
{ 
DependentTransaction dependentTransaction = transaction as DependentTransaction;
Debug.Assert(dependentTransaction != null); 
try
{
using(TransactionScope ts = new TransactionScope(dependentTransaction))
{
/*事物执行的代码 */ 
ts.Complete();
}
}
finally
{
dependentTransaction.Complete(); 
dependentTransaction.Dispose(); 
}
}
//客户代码块
using(TransactionScope scope = new TransactionScope())
{
Transaction currentTransaction = Transaction.Current;
DependentTransaction dependentTransaction;    
dependentTransaction = currentTransaction.DependentClone(                                      DependentCloneOption.BlockCommitUntilComplete);
WorkerThread workerThread = new WorkerThread();
workerThread.DoWork(dependentTransaction);
/* 执行一些事务代码 */
scope.Complete();
}
客户端代码创建一个事务范围，该事务范围还设置环境事务。您不应将环境事务传递到辅助线程。而是应通过对当前事务调用 DependentClone 方法来克隆当前（环境）事务，并将依存事务传递到辅助线程。ThreadMethod 方法在新线程上执行。客户端启动一个新线程，将依存事务作为 ThreadMethod 参数传递。因为依存事务是使用 BlockCommitUntilComplete 创建的，所以，您确保在完成对第二个线程的所有事务性工作并对依存事务调用 Complete 前，不会提交该事务。这意味着，如果新线程在对依存事务调用 Complete 前客户端的范围结束（当它尝试在 using 语句的末尾处置事务对象时），将阻止客户端代码的运行，直到对该依存事务调用 Complete。然后，事务可以完成提交或中止。并发问题有几个在您使用 DependentTransaction 类时需知道的其他并发问题：如果辅助线程回滚该事务，但父事务尝试提交它，则引发 TransactionAbortedException。您应该为事务中的每个辅助线程都创建新的依存克隆。不要将同一依存克隆传递给多个线程，因为它们当中只有一个线程能对它调用 Complete。如果该辅助线程生成一个新辅助线程，则确保从该依存克隆创建一个依存克隆并将其传递到新线程。
唐山迪锐软件:www.tsp2c.cn