asp.net - 在新线程中使用 Ninject

Question

我需要为长时间运行的任务启动一个新线程(写入文档存储、触发重新索引等)。

我在 ASP.Net MVC 网站中使用 Ninject。本质上，我想从我的 Http 请求生成一个新线程，它实例化它自己的对象，确保新线程中的 Http 请求不使用任何数据库连接等。我不确定使用什么来生成线程或如何配置 Ninject 以不从 Web 请求上下文重复使用我的数据库 session 。

下面是问题的基本序列图

我读过一些有关 Ninject 中命名范围的内容，但我不确定这是否有任何相关性。

将生成新线程的 CommandProcessor 的代码是:

public class CommandProcessor
{
   private IKernel _serviceLocator;

   public CommandProc(IKernel serviceLocator)
   {
       _serviceLocator = serviceLocator;
   }

   public void Process<TCommand>(TCommand command) where T : ICommand
   {
       var commandHandlers = _serviceLocator.Get<ICommandHandler<TCommand>>();

       foreach (var commandHandler in commandHandlers)
       {
           // I want this call to be asynchronous
           commandHandler.Handle(command);
       }
   }
}

提前致谢，

哈米什。

Answer 1

当您生成新线程时，从 Ninject 创建一个新的激活上下文以在线程中使用:

        Thread thread = new Thread(new ThreadStart(() =>
            {
                using (IActivationBlock activation = kernel.BeginBlock())
                {
                    var commandHandlers = activation.Get<ICommandHandler<TCommand>>();

                    foreach (var commandHandler in commandHandlers)
                    {
                        commandHandler.Handle(command);
                    }
                }
            }));
        thread.Start();