Почему метод OnActionExecuted моего ActionFilterAttribute запускается до завершения операции async?

Question

У меня есть действие фильтр NHibernate, который устанавливает и распоряжается сессия/сделки следующим образом:

public class NHibernateActionAttribute : ActionFilterAttribute 
{ 
    public ISessionFactory SessionFactory { get; set; } 

    public override void OnActionExecuting(ActionExecutingContext filterContext) 
    { 
     // inject nhibernate session into controller 
     // and start transaction 
    } 

    public override void OnActionExecuted(ActionExecutedContext filterContext) 
    { 
     // commit or rollback and dispose 
    } 
} 

события огнь штраф по методу синхронного действия, но когда у меня есть действие асинхронных такие, как показано ниже , метод OnActionExecuted фильтра действий срабатывает, как только возвращается первый метод async.

public void SomeOperationAsync(term) 
{ 
    object results = null 
    var worker = new BackgroundWorker(); 

    worker.DoWork += (o,e) => 
    { 
     // Do some lengthy DB query 
     AsyncManager.Parameters["result"] = results; 
     AsyncManager.OutstandingOperations.Decrement(); 
    }; 

    AsyncManager.OutstandingOperations.Increment(); 
    worker.RunWorkerAsync();   
    // OnActionExecuted fires NOW. 
} 

public ActionResult SomeOperationCompleted(object result) 
{ 
    return Json(result, JsonRequestBehavior.AllowGet); 
    // I would expect OnActionExecuted to fire NOW. 
} 

Проблема заключается в том, что, поскольку OnActionExecuted метод стрельбы в то время как моя асинхронная работа все еще делаются, запрос дб в фоновом режиме работника не удается, потому что сессия уже закрыта. Как я могу это исправить?

Answer 1

Я понятия не имею, как BackgroundWorker ведет себя в среде ASP.NET, но вы можете работать с классом Task. Попробуйте следующее:

public void SomeOperationAsync(term) { 

    AsyncManager.OutstandingOperations.Increment(); 

    Task<object>.Factory.StartNew(() => { 

     object results = null 

     // Do some lengthy DB query 

     return results; 

    }).ContinueWith(t => { 

     AsyncManager.Parameters["result"] = t.Result; 
     AsyncManager.OutstandingOperations.Decrement(); 
    }); 
}