blocks|key|3055562|text|您可以使用Transaction.DependentClone()方法创建的DependentTransaction：|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|3055563|static+void+Main(string[]+args)
{
++//+...

++for+(int+i+=+0;+i+<+10;+i%2B%2B)
++{

++++var+dtx+=+Transaction.Current.DependentClone(
++++++++DependentCloneOption.BlockCommitUntilComplete);

++++tasks[i]+=+TestStuff(dtx);
++}

++//...
}


static+async+Task+TestStuff(DependentTransaction+dtx)
{
++++using+(var+ts+=+new+TransactionScope(dtx))
++++{
++++++++//+do+transactional+stuff

++++++++ts.Complete();
++++}
++++dtx.Complete();
}|code-block|syntax|javascript|3055564|Managing+Concurrency+with+DependentTransaction|3055565|http://adamprescott.net/2012/10/04/transactionscope-in-multi-threaded-applications/|3055566|entityMap|0|LINK|mutability|MUTABLE|url|http://msdn.microsoft.com/en-us/library/system.transactions.transaction.dependentclone.aspx|1|http://msdn.microsoft.com/en-us/library/system.transactions.dependenttransaction.aspx|2|http://msdn.microsoft.com/en-us/library/ee818752.aspx|3^0|5|S|0|12|K|1|0|0|0|1A|2|0|0|2B|3|0^^$0|@$1|2|3|4|5|6|7|Z|8|@]|9|@$A|10|B|11|1|12]|$A|13|B|14|1|15]]|C|$]]|$1|D|3|E|5|F|7|16|8|@]|9|@]|C|$G|H]]|$1|I|3|J|5|6|7|17|8|@]|9|@$A|18|B|19|1|1A]]|C|$]]|$1|K|3|L|5|6|7|1B|8|@]|9|@$A|1C|B|1D|1|1E]]|C|$]]|$1|M|3|-4|5|6|7|1F|8|@]|9|@]|C|$]]]|N|$O|$5|P|Q|R|C|$S|T]]|U|$5|P|Q|R|C|$S|V]]|W|$5|P|Q|R|C|$S|X]]|Y|$5|P|Q|R|C|$S|L]]]]

You can use <a href="http://msdn.microsoft.com/en-us/library/system.transactions.dependenttransaction.aspx" rel="noreferrer">DependentTransaction</a> created by <a href="http://msdn.microsoft.com/en-us/library/system.transactions.transaction.dependentclone.aspx" rel="noreferrer">Transaction.DependentClone()</a> method:

<pre><code>static void Main(string[] args)
{
 // ...

 for (int i = 0; i &lt; 10; i++)
 {

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

 tasks[i] = TestStuff(dtx);
 }

 //...
}


static async Task TestStuff(DependentTransaction dtx)
{
 using (var ts = new TransactionScope(dtx))
 {
 // do transactional stuff

 ts.Complete();
 }
 dtx.Complete();
}
</code></pre>

<a href="http://msdn.microsoft.com/en-us/library/ee818752.aspx" rel="noreferrer">Managing Concurrency with DependentTransaction</a>

<a href="http://adamprescott.net/2012/10/04/transactionscope-in-multi-threaded-applications/" rel="noreferrer">http://adamprescott.net/2012/10/04/transactionscope-in-multi-threaded-applications/</a>

blocks|key|2842640|text|在.NET框架4.5.1中，有一组接受TransactionScopeAsyncFlowOption参数new+constructors+for+TransactionScope。|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|2842641|根据MSDN的说法，它支持跨线程延续的事务流。|2842642|我的理解是，它的目的是让你可以像这样写代码：|2842643|//+transaction+scope
using+(var+scope+=+new+TransactionScope(...+,
++TransactionScopeAsyncFlowOption.Enabled))
{
++//+connection
++using+(var+connection+=+new+SqlConnection(_connectionString))
++{
++++//+open+connection+asynchronously
++++await+connection.OpenAsync();

++++using+(var+command+=+connection.CreateCommand())
++++{
++++++command.CommandText+=+...;

++++++//+run+command+asynchronously
++++++using+(var+dataReader+=+await+command.ExecuteReaderAsync())
++++++{
++++++++while+(dataReader.Read())
++++++++{
++++++++++...
++++++++}
++++++}
++++}
++}
++scope.Complete();
}|code-block|syntax|javascript|2842644|entityMap|0|LINK|mutability|MUTABLE|url|http://msdn.microsoft.com/en-us/library/system.transactions.transactionscope(v=vs.110).aspx^0|J|V|21|G|1G|11|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|W|8|@$9|X|A|Y|B|C]|$9|Z|A|10|B|C]]|D|@$9|11|A|12|1|13]]|E|$]]|$1|F|3|G|5|6|7|14|8|@]|D|@]|E|$]]|$1|H|3|I|5|6|7|15|8|@]|D|@]|E|$]]|$1|J|3|K|5|L|7|16|8|@]|D|@]|E|$M|N]]|$1|O|3|-4|5|6|7|17|8|@]|D|@]|E|$]]]|P|$Q|$5|R|S|T|E|$U|V]]]]

In .NET Framework 4.5.1, there is a set of <a href="http://msdn.microsoft.com/en-us/library/system.transactions.transactionscope(v=vs.110).aspx" rel="noreferrer">new constructors for <code>TransactionScope</code></a> that take a <code>TransactionScopeAsyncFlowOption</code> parameter.

According to the MSDN, it enables transaction flow across thread continuations.

My understanding is that it is meant to allow you to write code like this:

<pre><code>// transaction scope
using (var scope = new TransactionScope(... ,
 TransactionScopeAsyncFlowOption.Enabled))
{
 // connection
 using (var connection = new SqlConnection(_connectionString))
 {
 // open connection asynchronously
 await connection.OpenAsync();

 using (var command = connection.CreateCommand())
 {
 command.CommandText = ...;

 // run command asynchronously
 using (var dataReader = await command.ExecuteReaderAsync())
 {
 while (dataReader.Read())
 {
 ...
 }
 }
 }
 }
 scope.Complete();
}
</code></pre>

blocks|key|2842649|text|回答有点晚了，但我在MVC4上遇到了同样的问题，我通过右键单击项目转到属性，将我的项目从4.5更新到4.5.1。选择application+tab，将target+framework更改为4.5.1，并使用transaction，如下所示。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|2842650|using+(AccountServiceClient+client+=+new+AccountServiceClient())
using+(TransactionScope+scope+=+new+TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
{
}|code-block|syntax|javascript|2842651|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

Bit late for an answer but I was having the same issue with MVC4 and I updated my project from 4.5 to 4.5.1 by right clicking on project go to properties. Select application tab change target framework to 4.5.1 and use transaction as follow.

<pre><code>using (AccountServiceClient client = new AccountServiceClient())
using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
{
}
</code></pre>

blocks|key|2842686|text|以防有人还在关注这个帖子...|type|unstyled|depth|inlineStyleRanges|entityRanges|data|2842687|Microsoft.Data.SqlClient+v3.0.1看起来修复了.NET框架异步/等待函数中System.Transactions的死锁问题！我用的是4.8。我使用了显式的分布式事务方法，通过使用多个连接来允许对单个sql+server执行并行查询，但我确信使用TransactionScope的行为也更好。|2842688|创建一个CommittableTransaction，创建任意数量的SqlConnections来登记从父提交表创建的DependentTransaction，在连接上并行执行查询，在查询执行后完成依赖项，然后提交/回滚父提交表。|2842689|我在3个不同的连接上对同一数据库进行了3次并行异步插入测试。当父提交表正在进行时，我使用了一个消息框来提示提交或回滚。当分布式事务处于活动状态时，表被锁定。我不能在ssms中从中选择。选择提交或回滚后，两者都能按预期工作。|2842690|上周在Microsoft.Data.SqlClient+3.0.0中，这是不可能的，因为.Commit()方法会在异步函数中死锁。我甚至用各种方法尝试了BeginCommit/EndCommit。甚至在异步函数中存在依赖项的问题，但该问题也已修复。现在，最简单的显式分布式事务方法使用async/await。|2842691|entityMap^0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|L|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|M|8|@]|9|@]|A|$]]|$1|D|3|E|5|6|7|N|8|@]|9|@]|A|$]]|$1|F|3|G|5|6|7|O|8|@]|9|@]|A|$]]|$1|H|3|I|5|6|7|P|8|@]|9|@]|A|$]]|$1|J|3|-4|5|6|7|Q|8|@]|9|@]|A|$]]]|K|$]]

In case anyone still follows this thread...
Microsoft.Data.SqlClient v3.0.1 looks like it fixes the deadlock issues with System.Transactions in async/await functions for .NET Framework! I'm using 4.8. I used the explicit distributed transaction method to allow for parallel query execution against a single sql server by using multiple connections, but I'm sure the behavior with TransactionScope is better too.
Create a CommittableTransaction, create any number of SqlConnections that enlist a DependentTransaction created from the parent committable, execute queries on the connections in parallel, complete the dependents after query execution, then commit/rollback the parent committable.
I tested it with 3 parallel async inserts to the same db on 3 different connections. While the parent committable is in progress, I used a messagebox to prompt for commit or rollback. While the distributed transaction is active, the tables were locked. I couldn't select from them in ssms. After selecting commit or rollback, either worked as expected.
Last week with Microsoft.Data.SqlClient 3.0.0, this was impossible because the .Commit() method would deadlock in an async function. I even tried BeginCommit/EndCommit with various methods. There was even a problem enlisting dependents in async functions, but that is fixed too. Now the simplest explicit distributed transaction method works with async/await.

I'm trying to integrate <code>async</code>/<code>await</code> into our service bus.
I implemented a <code>SingleThreadSynchronizationContext</code> based on this example <a href="http://blogs.msdn.com/b/pfxteam/archive/2012/01/20/10259049.aspx" rel="nofollow noreferrer">http://blogs.msdn.com/b/pfxteam/archive/2012/01/20/10259049.aspx</a>.
And it works fine, except for one thing: <code>TransactionScope</code>. I await for stuff inside the <code>TransactionScope</code> and it breaks the <code>TransactionScope</code>.
<code>TransactionScope</code> doesn't seem to play nice with <code>async</code>/<code>await</code>, certainly because it stores things in the thread using <code>ThreadStaticAttribute</code>. I get this exception:
<blockquote>
&quot;TransactionScope nested incorrectly.&quot;.
</blockquote>
I tried to save <code>TransactionScope</code> data before queuing the task and restore it before running it, but it doesn't seem to change a thing. And <code>TransactionScope</code> code is a mess, so it's really hard to understand what's going on there.
Is there a way to make it work? Is there some alternative to <code>TransactionScope</code>?

Get TransactionScope to work with async / await

数据库

我正在尝试将async/await集成到我们的服务总线中。我基于这个示例实现了一个SingleThreadSynchronizationContext。它工作得很好，除了一件事：TransactionScope。我在等待TransactionScope中的东西，它破坏了TransactionScope。Transact...

问让TransactionScope与异步/等待一起工作
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问让TransactionScope与异步/等待一起工作EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问让TransactionScope与异步/等待一起工作
EN