【发布时间】:2009-10-22 20:44:41
【问题描述】:
我终于弄清楚我的代码出了什么问题,但我不确定如何修复它。我有一些后台进程在执行一些数据库维护任务的单独线程上运行。这是正在发生的事情的一个例子:
//Both processes share the same instance of ISessionFactory
//but open separate ISessions
//This is running on it's own thread
public void ShortRunningTask()
{
using(var session = _sessionFactory.OpenSession())
{
//Do something quickly here
session.Update(myrecord);
}
}
//This is running on another thread
public void LongRunningTask()
{
using(var session = _sessionFactory.OpenSession())
{
//Do something long here
}
}
假设我首先开始LongRunningTask。当它运行时,我在另一个线程上启动ShortRunningTask。 ShortRunningTask 完成并关闭其会话。一旦LongRunningTask 完成,它会尝试对它创建的会话做一些事情,但会抛出一个错误,表明会话已经关闭。
很明显,发生的事情是 ISessionFactory.OpenSession() 不尊重我已经打开 2 个单独会话的事实。关闭ShortRunningTask 中打开的会话也会关闭LongRunningTask 中的会话我该如何解决这个问题?请帮忙!
谢谢!
更新
所以显然每个人都认为我的修复是完全错误的。所以这是我正在使用的配置:
_sessionFactory = Fluently.Configure()
.Database(
FluentNHibernate.Cfg.Db.MsSqlConfiguration.MsSql2008
.ConnectionString(db => db.Is(
WikipediaMaze.Core.Properties.Settings.Default.WikipediaMazeConnection)))
.Mappings(m => m.FluentMappings.AddFromAssemblyOf<IRepository>())
.BuildSessionFactory();
我没有在 xml 文件中进行配置。应该有吗?我错过了什么。以下是打开多个会话如何失败的另一个示例:
public void OpenMultipleSessionsTest()
{
using(var session1 = _sessionFactory.OpenSession())
{
var user = session1.Get<Users>().ById(1);
user.Name = "New Name";
using(var session2 = _sessionFactory.OpenSession())
{
//Do some other operation here.
}
session1.Update(user);
session1.Flush(); // Throws error 'ISession already closed!'
}
}
【问题讨论】:
-
您是否为其他线程创建了另一个
ISessionFactory? -
不,我没有。这是我需要做的吗?
-
会话工厂是完全线程安全的。请发布更多代码、错误、堆栈跟踪等。
-
看起来一些 SessionContext 是就地的。 Session Factory 是如何设置的?
-
What goes in "//在这里做一些其他的操作。" ?你能构建一个运行的、独立的测试用例吗?