4

根据这篇 MSDN 文章，您应该能够对一个进程进行多线程处理，每个线程都登记在一个根事务中。

我根据那篇文章创建了一个示例，我希望在其中回滚事务（bool[] results应该全部false在foreach循环中）。不幸的是，情况并非如此，结果是可以预见的（运行示例足够多次，您将看到bool数组中的任何值组合）。

此外，我已经尝试了这两种方法DependentCloneOption.BlockCommitUntilComplete，但都DependentCloneOption.RollbackIfNotComplete没有产生预期的结果。

其次，我认为ThreadPool.QueueUserWorkItem充其量是丑陋的代码，很高兴看到这样的东西Parallel.ForEach改为使用。

最后，我的问题:) 为什么这不起作用？我究竟做错了什么？在单个事务中包装多个线程是完全不可能的吗？

namespace Playing
{
    class Program
    {
        static bool[] results = new bool[] { false, false, false };

        static void Main(string[] args)
        {
            try
            {
                using (var outer = new TransactionScope(
                    TransactionScopeOption.Required))
                {
                    for (var i = 0; i < 3; i++ )
                    {
                        ThreadPool.QueueUserWorkItem(WorkerItem,
                            new Tuple<int, object>(
                                i, Transaction.Current.DependentClone(
                                    DependentCloneOption.BlockCommitUntilComplete)));
                    }
                    outer.Complete();
                }
            }
            catch { /* Suppress exceptions */ }

            // Expect all to be false
            foreach (var r in results)
                Console.WriteLine(r);
        }

        private static void WorkerItem(object state)
        {
            var tup = (Tuple<int, object>)state;
            var i = tup.Item1;
            var dependent = (DependentTransaction)tup.Item2;

            using (var inner = new TransactionScope(dependent))
            {
                // Intentionally throw exception to force roll-back
                if (i == 2)
                    throw new Exception();

                results[i] = true;
                inner.Complete();
            }
            dependent.Complete();
        }
    }
}
4

1 回答 1

4

已设置为 true 的您的 results[] 成员不会神奇地将自己设置为 false （遗憾的是）。这就是事务管理器所做的。查看 EnlistXXX 方法以了解所涉及的内容。

基本上，您需要在回滚时进行补偿。例如，您可以订阅根事务的 TransactionCompleted 事件并检查事务是否已回滚。如果是，您需要为已完成的童工恢复以前的值。

您还可以处理您正在抑制的 TransactionAbortedException，或在工作人员级别处理它（请参阅此页面上捕获它的示例：http: //msdn.microsoft.com/en-us/library/ms973865.aspx）

通常，使用内存中的“事务”，您最好使用任务库让工作人员批量处理结果，然后在父任务的延续中“提交”它们。这比搞乱事务更容易，只有在内存和其他一些事务管理器（如 SQL Server 或其他进程）之间进行协调时才需要这样做。

于 2013-10-09T13:36:58.517 回答