如何在无需等待的Task.Run中传递System.Diagnostics.Activity？

你的实现模式不完全正确，存在语法错误和Activity生命周期、追踪链关联的问题，以下是具体分析和正确实现：

你的代码存在的问题 #

1. 语法错误：Task.Run的Lambda表达式写法有误，缺少=>，正确格式应为() => { ... }
2. 追踪链断裂：直接启动新的parentActivity但未关联原工作流的上下文，会导致OpenTelemetry遥测数据的追踪链断开，出现混乱
3. 生命周期管理不规范：手动给Activity.Current赋值且在finally中Dispose的方式不够安全，若parentActivity提前被回收或采样未命中返回null，会引发潜在问题

正确实现方案 #

推荐通过启动关联父上下文的子Activity的方式，既保证追踪链连续，又规范管理Activity生命周期：

public void NotifyExternalServices()
{
    // 捕获当前工作流的父Activity上下文
    var parentActivity = Activity.Current;

    // Fire-and-Forget执行异步任务
    Task.Run(() =>
    {
        // 启动关联父Activity的子Activity，使用using块自动管理生命周期
        using var childActivity = MyActivitySource.StartActivity(
            name: "NotifyExternalServices",
            kind: ActivityKind.Client,
            parentContext: parentActivity?.Context);
        
        try
        {
            ExternalServices.NotifyOtherAll(new ThisHappenedEvent());
        }
        catch (Exception ex)
        {
            // 可选：给Activity标记错误状态，便于遥测系统排查问题
            childActivity?.SetStatus(ActivityStatusCode.Error, ex.Message);
        }
    });
}

方案说明 #

• 追踪链连续：通过传入parentActivity?.Context，让子Activity成为原工作流追踪链的一部分，避免遥测数据混乱
• 生命周期自动管理：using块会在代码块结束时自动Dispose子Activity，标记其完成状态，无需手动处理
• 符合语义规范：指定ActivityKind.Client符合OpenTelemetry对外部服务调用的语义定义，让遥测数据更易理解

特殊场景的替代方案 #

如果确实不需要启动新的子Activity，仅需复用原Activity上下文，可采用以下方式（不推荐，存在上下文失效风险）：

public void NotifyExternalServices()
{
    var originalActivity = Activity.Current;

    Task.Run(() =>
    {
        var previousActivity = Activity.Current;
        try
        {
            // 设置当前线程的Activity上下文为原工作流的Activity
            Activity.SetCurrentActivity(originalActivity);
            ExternalServices.NotifyOtherAll(new ThisHappenedEvent());
        }
        finally
        {
            // 恢复当前线程原有Activity上下文
            Activity.SetCurrentActivity(previousActivity);
        }
    });
}

内容的提问来源于stack exchange，提问作者Cine