首页
学习
活动
专区
工具
TVP
发布
社区首页 >问答首页 >LogicalOperationStack是否与.Net 4.5中的异步不兼容

LogicalOperationStack是否与.Net 4.5中的异步不兼容
EN

Stack Overflow用户
提问于 2015-02-28 00:12:41
回答 2查看 3.6K关注 0票数 19

Trace.CorrelationManager.LogicalOperationStack支持嵌套逻辑操作标识符,其中最常见的情况是日志记录(NDC)。它应该仍然与async-await一起工作吗?

下面是一个使用LogicalFlow的简单示例,它是我在LogicalOperationStack上的简单包装器

代码语言:javascript
复制
private static void Main() => OuterOperationAsync().GetAwaiter().GetResult();

private static async Task OuterOperationAsync()
{
    Console.WriteLine(LogicalFlow.CurrentOperationId);
    using (LogicalFlow.StartScope())
    {
        Console.WriteLine("\t" + LogicalFlow.CurrentOperationId);
        await InnerOperationAsync();
        Console.WriteLine("\t" + LogicalFlow.CurrentOperationId);
        await InnerOperationAsync();
        Console.WriteLine("\t" + LogicalFlow.CurrentOperationId);
    }
    Console.WriteLine(LogicalFlow.CurrentOperationId);
}

private static async Task InnerOperationAsync()
{
    using (LogicalFlow.StartScope())
    {
        await Task.Delay(100);
    }
}

LogicalFlow

代码语言:javascript
复制
public static class LogicalFlow
{
    public static Guid CurrentOperationId =>
        Trace.CorrelationManager.LogicalOperationStack.Count > 0
            ? (Guid) Trace.CorrelationManager.LogicalOperationStack.Peek()
            : Guid.Empty;

    public static IDisposable StartScope()
    {
        Trace.CorrelationManager.StartLogicalOperation();
        return new Stopper();
    }

    private static void StopScope() => 
        Trace.CorrelationManager.StopLogicalOperation();

    private class Stopper : IDisposable
    {
        private bool _isDisposed;
        public void Dispose()
        {
            if (!_isDisposed)
            {
                StopScope();
                _isDisposed = true;
            }
        }
    }
}

输出:

代码语言:javascript
复制
00000000-0000-0000-0000-000000000000
    49985135-1e39-404c-834a-9f12026d9b65
    54674452-e1c5-4b1b-91ed-6bd6ea725b98
    c6ec00fd-bff8-4bde-bf70-e073b6714ae5
54674452-e1c5-4b1b-91ed-6bd6ea725b98

具体的值并不重要,但据我所知,两行外部代码应该显示Guid.Empty (即00000000-0000-0000-0000-000000000000),内部代码行应该显示相同的Guid值。

您可能会说LogicalOperationStack使用的Stack不是线程安全的,这就是输出错误的原因。但是,虽然这通常是正确的,但在这种情况下,不会有超过一个线程同时访问 LogicalOperationStack (每个async操作在被调用时都是等待的,并且不使用诸如Task.WhenAll之类的组合符)。

问题是LogicalOperationStack存储在具有写入时复制行为的CallContext中。这意味着,只要您没有在CallContext中显式设置某些内容(当您使用StartLogicalOperation添加到现有堆栈时,您就不会这样做),您就是在使用父上下文,而不是您自己的上下文。

这可以通过在添加到现有堆栈之前将anything设置到CallContext中来显示。例如,如果我们将StartScope更改为:

代码语言:javascript
复制
public static IDisposable StartScope()
{
    CallContext.LogicalSetData("Bar", "Arnon");
    Trace.CorrelationManager.StartLogicalOperation();
    return new Stopper();
}

输出为:

代码语言:javascript
复制
00000000-0000-0000-0000-000000000000
    fdc22318-53ef-4ae5-83ff-6c3e3864e37a
    fdc22318-53ef-4ae5-83ff-6c3e3864e37a
    fdc22318-53ef-4ae5-83ff-6c3e3864e37a
00000000-0000-0000-0000-000000000000

注意:我并不是建议任何人真的这样做。真正实用的解决方案是使用ImmutableStack而不是LogicalOperationStack,因为它是线程安全的,而且由于它在调用Pop时是不可变的,所以您会得到一个新的ImmutableStack,然后需要将其设置回CallContext__中。一个完整的实现可以作为这个问题的答案:

那么,LogicalOperationStack应该与async一起工作,而它只是一个bug吗?是不是async世界不适合使用LogicalOperationStack?还是我错过了什么?

更新:使用Task.Delay显然令人困惑,因为它使用的System.Threading.Timercaptures the ExecutionContext internally。使用await Task.Yield();而不是await Task.Delay(100);可以使示例更容易理解。

EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/28769483

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档