在新线程中使用Ninject

Question

我需要启动一个新线程来执行长时间运行的任务（写入文档存储，触发重新索引等）。

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

以下是问题的基本序列图

我已经阅读了有关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);
       }
   }
}

感谢您事先的支持。

Hamish。

- HCdev

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();

- Dave Thieben

---

嗯，这会使DB上下文从Web请求范围变为瞬态，不是吗？ - Anders