如何在属于不同类的不同线程之间共享数据？答案

【问题标题】：How to share data between different threads which belong to different classes?如何在属于不同类的不同线程之间共享数据？
【发布时间】：2018-03-25 11:45:04
【问题描述】：

我最近正在阅读有关 async/await 的内容，我想知道如何在属于不同类的不同线程之间共享数据？假设我们在某个 Web 应用程序中有 HttpContext。此上下文包含有关userId、sessionId 等的信息。我们的 Web 应用程序提供了一些数据，这些数据由在另一台计算机上执行的某些控制台应用程序使用。如果此控制台应用程序发生错误，我会将其写入日志文件。 userId 和 sessionId 也应写入此日志文件。但是在这个控制台应用程序中创建的每个线程都有自己的上下文。所以，我正在寻找一种将userId 和sessionId 设置为线程上下文的方法。我不想使用一些静态类或volatile 字段。我在下面放了一个我的控制台应用程序的简单示例。

    public sealed class MainService
    {
        /// <summary>
        /// The main method which is called.
        /// </summary>
        public void Execute()
        {
            try
            {
                searchService.ExecuteSearchAsync().Wait();
            }
            catch (Exception e)
            {
                // gets additional info (userId, sessionId) from the thread context
                StaticLoggerClass.LogError(e);
            }
        }
    }

    public sealed class SearchService
    {
        private IRepository  repository = new Repository();

        public async Task ExecuteSearchAsync()
        {
            try
            {
                var result = await this.GetResultsAsync();
            }
            catch (Exception e)
            {
                // gets additional info (userId, sessionId) from the thread context
                StaticLoggerClass.LogError(e);
            }
        }

        private async Task<ResultModel> GetResultsAsync()
        {
            var result = this.repository.GetAsync();
        }
    }

    public sealed class Repository
    {
        private IClient client;

        public async Task<Entity> GetAsync()
        {
            return await client.GetResultAsync();
        }
    }

【问题讨论】：

线程不属于类。您的代码无论如何都没有使用线程，它使用异步方法。不需要跨线程同步 - await 确保执行将在正确的上下文中继续。当然，除非你用 searchService.ExecuteSearchAsync().Wait(); 阻止它，这意味着没有 await 能够返回
不太确定你要做什么，但听起来你可以通过传递 userId 和 sessionId 作为方法参数来做到这一点
您的问题是什么？你想做什么？你遇到实际问题了吗？这段代码中唯一的问题是public void Execute() 和对Wait() 的调用。该方法应该是异步的
至于日志记录，您使用的是哪个记录器？不同的记录器使用不同的技术来传递环境属性，而不依赖于线程上下文，准确地说，因为这会随着任务而变化。如果您编写自己的记录器并遇到问题，请发布记录器的代码
@PanagiotisKanavos 我有一个 static 记录器类，它执行写入日志文件。它用于Web应用程序和控制台应用程序。它从线程上下文中获取数据。这是 Web 应用程序中的 HttpContext。但我的吊顶申请中没有userId 和sessionId。我认为我应该将其设置为控制台应用程序的上下文。

标签： c# multithreading threadcontext

【解决方案1】：

几乎从来没有必要将数据“设置到线程上下文”，所以别想了。

考虑线程安全是件好事——大多数问题都是因为人们没有考虑。但是，在这种情况下不需要有两个原因：

从你所说的，userId 和 sessionId 在这个例子的生活。许多请求可能同时运行，但每个堆栈都有自己的用户 ID/会话 ID
我打赌 userid/sessionid 是不可变类型 - 即不能改变了。如果它们是字符串、整数或任何值，就会出现这种情况输入。

因此，考虑到这一点，您可以这样做：

public sealed class MainService
{
    /// <summary>
    /// The main method which is called.
    /// </summary>
    public void Execute()
    {
        try
        {
            // somehow get the userid/sessionid, you don't say where these are from
            var userId = "?";
            var sessionId = "?"

            searchService.ExecuteSearchAsync(userId, sessionId).Wait();
        }
        catch (Exception e)
        {
            // gets additional info (userId, sessionId) from the thread context
            StaticLoggerClass.LogError(e);
        }
    }
}

public sealed class SearchService
{
    private IRepository  repository = new Repository();

    public async Task ExecuteSearchAsync(string userId, string sessionId)
    {
        try
        {
            var result = await this.GetResultsAsync();
        }
        catch (Exception e)
        {
            // gets additional info (userId, sessionId) from the thread context
            StaticLoggerClass.LogError($"userId={userId}; sessionId={sessionId}; error={e}");
        }
    }

    // ........ 
    private async Task<ResultModel> GetResultsAsync()
    {
        var result = this.repository.GetAsync();
    }
}

【讨论】：