我需要为长时间运行的任务启动一个新线程(写入文档存储,触发重新索引等).
我在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();