2015-11-06 21 views
3

我重写了我的DbContextSaveChangesAsync方法来调用一堆存储过程。首先我打电话SaveChangesAsyncDbContext,之后我为每个更改的实体执行一个存储过程。EF 6 - 在SaveChangesAsync方法中执行SQL命令的异步抛出NotSupportedException

所有的异步方法调用都在等待。

这是异常的EF抛出:

System.NotSupportedException: A second operation started on this context before a previous asynchronous operation completed. Use 'await' to ensure that any asynchronous operations have completed before calling another method on this context. Any instance members are not guaranteed to be thread safe. 
    at System.Data.Entity.Internal.ThrowingMonitor.EnsureNotEntered() 
    at System.Data.Entity.Core.Objects.ObjectContext.ExecuteStoreCommandAsync(TransactionalBehavior transactionalBehavior, String commandText, CancellationToken cancellationToken, Object[] parameters) 
    at System.Data.Entity.Internal.InternalContext.ExecuteSqlCommandAsync(TransactionalBehavior transactionalBehavior, String sql, CancellationToken cancellationToken, Object[] parameters) 
    at System.Data.Entity.Database.ExecuteSqlCommandAsync(TransactionalBehavior transactionalBehavior, String sql, CancellationToken cancellationToken, Object[] parameters) 
    at System.Data.Entity.Database.ExecuteSqlCommandAsync(String sql, CancellationToken cancellationToken, Object[] parameters) 
    at System.Data.Entity.Database.ExecuteSqlCommandAsync(String sql, Object[] parameters) 
    at Common.Dal.AuditDbContext.<>c__DisplayClass20_0.<WriteAuditsParallelAsync>b__0(Audit x) in 
    at System.Linq.Enumerable.WhereSelectListIterator`2.MoveNext() 
    at System.Threading.Tasks.Task.WhenAll[TResult](IEnumerable`1 tasks) 
    at Common.Dal.AuditDbContext.<WriteAuditsParallelAsync>d__20.MoveNext() in 
--- End of stack trace from previous location where exception was thrown --- 
    at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task) 
    at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) 
    at System.Runtime.CompilerServices.TaskAwaiter.GetResult() 
    at Common.Dal.AuditDbContext.<SaveToDatabaseAsync>d__18.MoveNext() in 

这是我的代码:

public override Task<Int32> SaveChangesAsync(CancellationToken cancellationToken) 
{ 
    var modified = this.GetModifiedOrDeletedEntities(); 
    var added = this.GetAddedEntities(); 

    var audits = AuditService.GetAudits(GetObjectStateManager(), modified); 

    //Call SaveChangesAsync 
    var result = await base.SaveChangesAsync(cancellationToken); 

    audits.AddRange(AuditService.GetAudits(GetObjectStateManager(), added)); 

    //Call stored prcedures 
    await WriteAuditsAsync(audits, user); 

    return result; 
} 

private async Task WriteAuditsAsync(List<Audit> audits, String user) 
{ 
    foreach (var audit in audits) 
    { 
     try 
     { 
      ... 
      //Execute SQL command 
      await Database.ExecuteSqlCommandAsync(myCommand, myParameters); 
     } 
     catch (Exception ex) 
     { 
      Console.WriteLine(ex); 
     } 
    } 
} 

为什么EF抛出此异常?

+0

你还在等待'SaveChangesAsync'和'WriteAuditsAsync'吗? – Default

+0

'WriteAuditsParallelAsync'看起来可疑 - 您确定您正在将调用同步到数据库吗? – Default

+0

是的,我会等待SaveChangesAsync和WriteAuditsAsync(用于WriteAuditsAsync请参阅代码) – musium

回答

3

看看例外情况,您可以看到您在WriteAuditsParallelAsync中调用Task.WhenAll,这意味着您要同时启动多个异步操作,并且要异步等待所有这些操作完成。

您不能在EF上下文中同时执行多个单一操作,这就是它抛出的原因。

通过按顺序执行这些操作,您可以通过逐个启动和等待它们来解决该问题。