run - create async method c#

Obtener TransactionScope para trabajar con async/await

Question

async integrar async / await en nuestro bus de servicio. Implementé un SingleThreadSynchronizationContext basado en este ejemplo http://blogs.msdn.com/b/pfxteam/archive/2012/01/20/10259049.aspx .

Y funciona bien, excepto por una cosa: TransactionScope . Espero cosas dentro de TransactionScope y rompe el TransactionScope .

TransactionScope no parece funcionar bien con async / await , sin duda porque almacena cosas en el hilo usando ThreadStaticAttribute . Obtengo esta excepción:

"TransactionScope anidado incorrectamente".

Traté de guardar los datos de TransactionScope antes de poner en cola la tarea y restaurarla antes de ejecutarla, pero parece que no cambia nada. Y el código de TransactionScope es un desastre, por lo que es realmente difícil entender lo que sucede allí.

¿Hay alguna manera de hacerlo funcionar? ¿Hay alguna alternativa a TransactionScope ?

Answer 1

En .NET Framework 4.5.1, hay un conjunto de nuevos constructores para TransactionScope que toman un parámetro TransactionScopeAsyncFlowOption .

De acuerdo con MSDN, permite el flujo de transacciones a través de continuaciones de subprocesos.

Según entiendo, está destinado a permitir que escribas código como este:

// 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();
}

Answer 2

Puede usar DependentTransaction creado por el método Transaction.DependentClone() :

static void Main(string[] args)
{
// ...
for (int i = 0; i < 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();
}

Administrar la concurrencia con DependentTransaction

http://adamprescott.net/2012/10/04/transactionscope-in-multi-threaded-applications/

Answer 3

Un poco tarde para obtener una respuesta, pero estaba teniendo el mismo problema con MVC4 y actualicé mi proyecto de 4.5 a 4.5.1 haciendo clic derecho en el proyecto, vaya a las propiedades. Seleccione la pestaña de la aplicación, cambie el marco de destino a 4.5.1 y use la transacción de la siguiente manera.

using (AccountServiceClient client = new AccountServiceClient())
using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
{
}