在工作线程中通过Dependency Injection实例化对象的技术问询

我之前也碰到过一模一样的困境——想在并行线程里跑一个永不停止的常驻进程，但项目里用了DI，直接在新线程里实例化工作服务根本走不通，要么是DI上下文不对，要么是生命周期冲突。你调研到的**抽象工厂模式（Abstract Factory）**确实是这个场景下的黄金方案，下面给你拆解具体怎么落地：

• 核心逻辑：别直接把工作服务注入到线程启动器里，而是注入一个抽象工厂。这样线程就能通过工厂动态创建线程安全的服务实例，既符合DI的生命周期管理规则，又能完美避开跨线程的DI上下文问题。

• 具体实现步骤：

  1. 先给你的工作服务定义一个接口，比如IWorkerService，务必保证它的实现是线程安全的（比如设计成无状态，或者内部有完善的线程同步机制）。
  2. 定义对应的抽象工厂接口IWorkerServiceFactory，里面只需要一个创建实例的方法：IWorkerService CreateWorkerService();。
  3. 在DI容器里注册工厂的具体实现——如果你的工作服务本身有依赖，可以在工厂里注入IServiceProvider，通过它来创建服务实例；如果是简单服务，直接new就行。
  4. 编写你的线程启动器，注入这个抽象工厂，在新线程里通过工厂创建服务实例，然后执行长期运行的逻辑。

给你贴个可直接参考的代码示例：

// 工作服务接口：定义长期运行任务的契约
public interface IWorkerService
{
    void RunLongRunningTask(CancellationToken cancellationToken = default);
}

// 抽象工厂接口：负责创建工作服务实例
public interface IWorkerServiceFactory
{
    IWorkerService CreateWorkerService();
}

// 工厂实现：借助IServiceProvider创建带依赖的服务实例
public class WorkerServiceFactory : IWorkerServiceFactory
{
    private readonly IServiceProvider _serviceProvider;

    public WorkerServiceFactory(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
    }

    public IWorkerService CreateWorkerService()
    {
        // 通过DI容器获取线程安全的服务实例
        return _serviceProvider.GetRequiredService<IWorkerService>();
    }
}

/// <summary>
/// 负责启动并行的长期运行工作线程
/// </summary>
public class WorkerThreadStarter
{
    private readonly IWorkerServiceFactory _workerFactory;
    private CancellationTokenSource _cts;

    public WorkerThreadStarter(IWorkerServiceFactory workerFactory)
    {
        _workerFactory = workerFactory;
    }

    public void StartLongRunningThread()
    {
        _cts = new CancellationTokenSource();
        var token = _cts.Token;

        // 创建并启动后台线程
        Thread longRunningThread = new Thread(() =>
        {
            // 在线程内通过工厂获取服务实例
            var worker = _workerFactory.CreateWorkerService();
            
            while (!token.IsCancellationRequested)
            {
                try
                {
                    worker.RunLongRunningTask(token);
                    // 可选：添加间隔，避免CPU空转
                    Thread.Sleep(TimeSpan.FromSeconds(1));
                }
                catch (OperationCanceledException)
                {
                    // 处理取消逻辑，优雅退出
                    break;
                }
                catch (Exception ex)
                {
                    // 这里可以加日志记录异常，避免线程崩溃
                    Console.WriteLine($"任务执行出错：{ex.Message}");
                }
            }
        });

        longRunningThread.IsBackground = true; // 设置为后台线程，不阻止应用关闭
        longRunningThread.Start();
    }

    // 提供停止线程的方法
    public void StopLongRunningThread()
    {
        _cts?.Cancel();
        _cts?.Dispose();
    }
}

最后再提两个关键注意点：

• 一定要确保IWorkerService的实现是线程安全的！如果是有状态服务，记得用lock或者线程安全的数据结构来处理共享资源。
• 加入CancellationToken是个好习惯，能让你优雅地停止线程，而不是粗暴地终止。

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