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

发布时间：2020-12-16 09:47:32 所属栏目：asp.Net 来源：网络整理

导读：我需要为长时间运行的任务启动一个新线程(写入文档存储,触发重新索引等). 我在ASP.Net MVC网站上使用Ninject.本质上,我想从我的Http请求中生成一个新线程,该线程实例化它自己的对象,确保在新线程中没有使用Http Request中的数据库连接等.我不确定要使用什么

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

我在ASP.Net MVC网站上使用Ninject.本质上,我想从我的Http请求中生成一个新线程,该线程实例化它自己的对象,确保在新线程中没有使用Http Request中的数据库连接等.我不确定要使用什么来生成线程,或者如何配置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);
       }
   }
}

提前致谢,

哈米什.

解决方法

当您生成新线程时,从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();

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!