问题 UOW - 在上一次异步操作完成之前,在此上下文中启动了第二个操作


我正在尝试下面的代码,它有两个部分,一个是通过棱镜导航。 当允许导航时,我以异步方式开始深度加载,但每次都使用新的上下文。在以后的代码中,我想要取消未完成此加载的待处理导航,但下面的代码甚至不起作用,因此取消是稍后的事情;-)

导航逻辑:这里没问题

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'确保在此上下文上调用另一个方法之前已完成任何异步操作。任何实例成员都不保证是线程安全的。

编辑 (删除了记录器代码以减少代码大小)


8779
2018-02-04 20:55


起源

请注意,createUnitOfWorkAsync()不是异步方法。它只是创建了一个支持异步等待范例的类。 - Philip Stuyck
createUnitOfWorkAsync 确实创造了一个 新 情境,对吗? - Stephen Cleary
ConfigureAwait(true); 这是第一个计时器.. - Yuval Itzchakov
ConfigureAwait(true)是默认行为,您不需要添加它。 - Kai Brummund
那么对于SO id建议删除儿子不必要的代码,以便人们更容易找到代码的相关部分来帮助你(例如在所有这些日志记录之间很难找到你的问题)。 - Kai Brummund


答案:


问题是这段代码:

_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而不是它自己的,因为它被覆盖了。 不是那么容易发现,而是简单的竞争条件。 我通过用局部变量替换所有实例变量来找到它,然后问题就失败了。


14
2018-02-05 19:07



当你说“通过用local替换实例变量来解决这个问题”时,你是指方法中的变量并用在实例类中创建为字段的变量替换它们吗?只是对知识感到好奇。 - Daniel Jackson
我的意思相反,局部变量具有声明它的方法的范围,而实例变量范围与它包含的对象的实例一样长。 - Philip Stuyck
好的,我明白你的意思了。我还在学习。我想我需要更多地理解使用async / await编程,因为我在没有完全了解它的情况下这样做,而且我遇到了与上面相同的问题。当我改回直接同步时,我不再有这些问题了。 - Daniel Jackson


这可能不是答案,而是对代码的一般看法。

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

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

初看,您的代码看起来 精细 截至异步调用。也许您的深度加载会被多次触发?


1
2018-02-05 02:36



感谢您的评论,我这样做是因为我希望能够使用取消令牌在下一个增量中取消操作。方法loadRelatieAsync被多次调用并且正在并发运行,因为还没有取消,但这应该无关紧要,因为我每次都使用不同的上下文。它创建于单元工作创建之下。你是对的我想尽可能地解锁GUI线程,但我也希望能够取消挂起的导航操作 - Philip Stuyck
您仍然只能检查您的操作之间的取消请求,这将没有任何区别。 - Kai Brummund
为什么不检查,如果已经启动了加载操作并返回它的任务,如果它已经存在?您是否100%确定您的背景?因为当正在进行的事务导致您的错误时,这很可能就是问题所在。 - Kai Brummund