UOW - 在上一个异步操作完成之前，第二个操作在此上下文中开始

Question

我正在尝试下面的代码，它有两个部分，一个是通过棱镜导航。当允许导航时，我会异步启动深度加载，但每次都有一个新的上下文。在后面的代码中，我想取消未完成此加载的挂起导航，但下面的代码甚至不起作用，所以取消是以后的事;-)

导航逻辑：这里没有问题

public void OnNavigatedTo(NavigationContext navigationContext)
{
    int relatieId = (int)navigationContext.Parameters["RelatieId"];
    if (_relatie != null && _relatie.RelatieId == relatieId) return;

    loadRelatieAsync(relatieId);
}

public void ConfirmNavigationRequest(NavigationContext navigationContext, Action<bool> continuationCallback)
{
    bool navigationAllowed = true;
    continuationCallback(navigationAllowed);
}

深度加载逻辑：

private async Task loadRelatieAsync(int relatieId)
{
    try
    {
        await Task.Run(async () =>
        {

            _unitOfWork = _UnitOfWorkFactory.createUnitOfWorkAsync();

            IEnumerable<Relatie> relaties = await getRelatieAsync(_unitOfWork, relatieId).ConfigureAwait(true);

            _relatieTypeTypes = await getRelatieTypeTypesAsync(_unitOfWork, relatieId).ConfigureAwait(true);
            _relatie = relaties.FirstOrDefault();

            _unitOfWork.Dispose();
        }).ConfigureAwait(true);

        processRelatie(_relatie);

        processRelatieTypes(_relatie, _relatieTypeTypes);
    }
    catch (Exception Ex)
    {

        MessageBox.Show(Ex.Message);
        throw;
    }

}

private async Task<IEnumerable<Relatie>> getRelatieAsync(IUnitOfWorkAsync unitOfWork, int relatieId)
{

    IEnumerable<Relatie> relaties = null;
    try
    {
        IRepositoryAsync<Relatie> relatieRepository = unitOfWork.RepositoryAsync<Relatie>();
        relaties = await relatieRepository
            .Query(r => r.RelatieId == relatieId)
            .Include(i => i.BegrafenisOndernemer)
            .SelectAsync()
            .ConfigureAwait(false);

        IRepositoryAsync<Adres> adresRepository = unitOfWork.RepositoryAsync<Adres>();
        //exception is thrown after executing following line
        var adressen = await adresRepository
            .Query(r => r.RelatieId == relatieId)
            .Include(i => i.AdresType)
            .SelectAsync()
            .ConfigureAwait(false);
        _relatieTypeRepository = unitOfWork.RepositoryAsync<RelatieType>();
        var relatieTypes = await _relatieTypeRepository
            .Query(r => r.RelatieId == relatieId)
            .SelectAsync()
            .ConfigureAwait(false);
    }
    catch (Exception Ex)
    {
        MessageBox.Show(Ex.Message);//exception is shown here
        throw;
    }
    return relaties;
}

private async Task<IEnumerable<RelatieTypeType>> getRelatieTypeTypesAsync(IUnitOfWorkAsync unitOfWork, int relatieId)
{

    IEnumerable<RelatieTypeType> relatieTypeTypes = null;
    try
    {
        IRepositoryAsync<RelatieTypeType> relatieTypeTypeRepository =
            unitOfWork.RepositoryAsync<RelatieTypeType>();

        relatieTypeTypes = await relatieTypeTypeRepository
            .Query()
            .SelectAsync()
            .ConfigureAwait(false);

    }
    catch (Exception Ex)
    {
        MessageBox.Show(Ex.Message);
        throw;
    }
    return relatieTypeTypes;
}

我一直收到异常，就好像我忘记等待一样，但事实并非如此。每当我想在 GUI 线程上继续时，我也会正确地使用 configureawait(true) 。但是我在深度加载逻辑中不断收到这个错误。工作单元和存储库类也使用异步等待机制，但我也在正确等待。

在上一个异步操作完成之前，第二个操作开始在此上下文中。使用 'await' 确保所有异步操作都已完成，然后再在此上下文中调用另一个方法。不保证任何实例成员都是线程安全的。

编辑（删除记录器代码以减小代码大小）

Answer 1

这可能不是答案，而是对您的代码的一般查看。

async/await 的主要目的是保持当前线程可用。这有助于不阻塞 UI 线程并保持您的应用响应。

您已经确保深度加载发生在 ThreadPool 线程上，因为您完全利用 Task.Run() 启动它。您可能可以通过在加载机制中使用 EntityFramework 的默认同步方法来解决大部分问题。

乍一看，您的代码在异步调用时看起来很好。也许你的深度加载被触发了多次？

Answer 2

问题是这段代码：

_unitOfWork = _UnitOfWorkFactory.createUnitOfWorkAsync();

IEnumerable<Relatie> relaties = await getRelatieAsync(_unitOfWork, relatieId).ConfigureAwait(true);

_relatieTypeTypes = await getRelatieTypeTypesAsync(_unitOfWork, relatieId).ConfigureAwait(true);
_relatie = relaties.FirstOrDefault();

 _unitOfWork.Dispose();

UnitOfWork是一个实例变量，当场景第二次启动时，它会被一个新的实例覆盖。已经执行的场景然后使用那个新的 UnitOfWork 而不是它自己的，因为它被覆盖了。不是那么容易发现，而是一个简单的竞争条件。我通过将所有实例变量替换为局部变量找到了它，然后问题就消失了。

UOW - 在上一个异步操作完成之前，第二个操作在此上下文中开始

UOW - A second operation started on this context before a previous asynchronous operation completed

c#

async-await

entity-framework-6