每个请求实现的 NHibernate 会话

Question

我想用每个请求实现的会话来重建多线程 NHibernate 应用程序。

现在这个应用程序看起来像每个会话（每个线程）的会话，并将会话保存到 CurrentSessionContext 中。

但是这种实现带来了加载缓存实体的问题，这些实体可能已经从其他会话中更新。所以我想改变这段代码

//main thread 
using (nHibernateHelper.OpenConnection()){
    List<Bar> bars = BarRepository.Instance.GetAll();
    foreach (Bar bar in bars){
        //start thread and do some work, for example run DoWork(bar); by other thread
        Task.Factory.StartNew(DoWork, bar);
    }
}

//other thread
void DoWork(Bar bar){
    using (nHibernateHelper.OpenConnection()){
        foreach (Foo foo in bar.FooList){
            if (foo.SomeState == PredifinedState) {
                //call many other functions
            }
        }
    }
}

主要问题是：如何更改此代码，在使用 LazyLoading 启动其他线程之前关闭 Session（Bar 包含与其他对象的关系，并且在线程工作期间使用此关系），以及在从 foreach 语句调用其他函数之前DoWork 函数？

Answer 1

在 NHibernate 中，会话显然不是线程安全的（请参阅http://nhibernate.info/doc/nh/en/index.html#transactions），因此您不能在没有锁定的情况下在多个线程之间共享它们。

如果没有更多关于您的问题的背景信息，很难提供一个准确的解决方案，但是下面的内容会有所帮助吗？

//main thread 

    List<Bar> bars = BarRepository.Instance.GetAll();
    foreach (Bar bar in bars){
        //start thread and do some work, for example run DoWork(bar); by other thread
        Task.Factory.StartNew(DoWork, bar, NHibernateHelper.CurrentSession());
    }

void DoWork(Bar bar, ISession session){
    foreach (Foo foo in bar.FooList){
        if (foo.SomeState == PredifinedState) {
            //call many other functions
            lock (session)
            {
                using (var tran = session.BeginTransaction())
                {
                    session.Save(foo);
                    tran.Commit();
                }                
        }
    }
}