Проблема многопоточности NHibernate

Question

У меня есть приложение ASP.NET MVC, для которого я хочу написать несколько стресс-тестов в смысле одновременного доступа к базе данных из нескольких потоков.Я написал его как модульный тест с использованием Parallel.ForEach (), но не смог заставить его работать, так как большую часть времени получал следующее исключение:

There is already an open DataReader associated with this Command which must be closed first

Поэтому я упростил тестнасколько это возможно, и здесь это

[Test]
public void Can_Access_DB_Concurrently()
{
    Parallel.ForEach(Enumerable.Range(0, 9), x =>
    {
        try
        {
            var sessionBuilder = new HybridSessionBuilder();             
            var session = sessionBuilder.GetSession();

             using (ITransaction transaction = session.BeginTransaction())
             {
                 var job = session.Query<Job>().Where(y => y.Name == "TestProject").SingleOrDefault().Name;
                 Trace.WriteLine(Thread.CurrentThread.ManagedThreadId + ": Job name is " + job);
                 transaction.Commit();
             }                
        }
        catch (Exception e)
        {
            Trace.WriteLine(Thread.CurrentThread.ManagedThreadId + ": Exception: " + e.Message);
        }
    });
}

Типичный вывод:

13: Exception: Object reference not set to an instance of an object.
16: Exception: There is already an open DataReader associated with this Command which must be closed first.
9: Exception: There is already an open DataReader associated with this Command which must be closed first.
16: Exception: There is already an open DataReader associated with this Command which must be closed first.
14: Exception: There is already an open DataReader associated with this Command which must be closed first.

HybridSessionBuilder выглядит так:

public class HybridSessionBuilder : ISessionBuilder
{
    private static ISessionFactory _sessionFactory;
    private static ISession _currentSession;

    public ISession GetSession()
    {
        ISessionFactory factory = getSessionFactory();
        ISession session = getExistingOrNewSession(factory);
        return session;
    }

    private ISessionFactory getSessionFactory()
    {
        lock (this)
        {
            if (_sessionFactory == null)
            {
                Configuration configuration = GetConfiguration();
                _sessionFactory = configuration.BuildSessionFactory();
            }

            return _sessionFactory;
        }
    }

    public Configuration GetConfiguration()
    {
        string connectionString = WebConfigurationManager.ConnectionStrings["StagingDatabase"].ConnectionString;

        Configuration configuration = new Configuration();
        configuration = PostgreSQLConfiguration.PostgreSQL82
              .ConnectionString(connectionString)
              .Dialect("NHibernate.Dialect.PostgreSQL82Dialect")
              .UseReflectionOptimizer()
              .AdoNetBatchSize(50)
              .ConfigureProperties(new Configuration());

        configuration.AddMappingsFromAssembly(typeof(Job).Assembly);
        Fluently.Configure(configuration);
        return configuration;
    }

    private ISession getExistingOrNewSession(ISessionFactory factory)
    {
        {
            if (HttpContext.Current != null)
            {
                ISession session = GetExistingWebSession();
                if (session == null)
                {
                    session = openSessionAndAddToContext(factory);
                }
                else if (!session.IsOpen)
                {
                    session = openSessionAndAddToContext(factory);
                }

                return session;
            }

            if (_currentSession == null)
            {
                _currentSession = factory.OpenSession();
            }
            else if (!_currentSession.IsOpen)
            {
                _currentSession = factory.OpenSession();
            }
        }

        return _currentSession;
    }        

    public ISession GetExistingWebSession()
    {
        return HttpContext.Current.Items[GetType().FullName] as ISession;
    }

    private ISession openSessionAndAddToContext(ISessionFactory factory)
    {
        ISession session = factory.OpenSession();
        HttpContext.Current.Items.Remove(GetType().FullName);
        HttpContext.Current.Items.Add(GetType().FullName, session);
        return session;
    }        
}

Видимо, я делаю что-то не такс этим одновременным доступом, но я не могу определить ошибку.Спасибо за любой совет.

Answer 1

HybridSessionBuilder сохраняет ISession в статическом члене и поэтому повторно использует его для каждого потока.Самым простым решением для исправления ваших тестов было бы удаление ключевого слова static из _currentSession.Каждый экземпляр HybridSessionBuilder будет предоставлять различный ISession.