4

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

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

下面是问题的基本时序图

我在 Ninject 中读过一些关于命名作用域的信息，但我不确定是否有任何相关性。

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

提前致谢，

哈米什。

4

1 回答 1

2

当您生成新线程时，从 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();
于 2012-08-15T15:23:30.633 回答