NHibernate、多线程和共享对象更新冲突

我知道ISession不是线程安全的，SessionFactory是线程安全的。因此，我已经结束并确认每个线程有一个会话。

在以下情况下，我收到了一个错误，我想知道这是否是不支持的，或者我的ISession线程隔离仍然缺少一些东西。

我正在运行NUnit测试。我有一个场景，其中我的实体作为字段变量被截断。我有一个运行两个并行任务的测试。

•每个并行任务都从同一个SessionFactory创建自己的会话，并开始一个NHibernate事务
•它们分别更新实体并对其执行SaveOrUpdate。
•然后提交并关闭交易
每项任务完成约1万次。

在这次测试中，我收到了一条消息：

System.AggregateException : One or more errors occurred.
  ----> NHibernate.HibernateException : identifier of an instance of Domain.Entity.MyEntity was altered from 2 to 1

这是有意义的，因为MyEntity是一个字段对象，由两个线程使用。因此，在NUnit类中创建的单个对象被两个线程引用和更新。

我的问题是，这样的场景是否可以通过悲观锁定或其他NHibernate功能来避免？或者这是不可行的，我必须确保这种情况（即，我的实体对象一次没有被多个线程引用和更新）永远不会发生在我的代码中？

我已经厌倦了NHibernate中的一些选项，比如确保实体的版本控制，并尝试了一些锁定调用，但我在文档中猜测这是处理这种情况的正确方法（如果有的话）。

编辑：谢谢你的评论！这是单元测试中的代码：

private PluginConfiguration _configStub1;
    [SetUp]
    public void Setup()
    {
        new FluentMapper().Configuration().ExposeConfiguration(
            e => new SchemaExport(e).Drop(false, true)
            );
        _configStub1 = new PluginConfiguration()
            {
                Enabled = true,
                Keys = "Name",
                Value = "Fred",
                PluginName = "red",
                RuntimeId = 1
            };
     }
    [Test]
    [Explicit]
    public void HighVolume_Saves_MultiManager_SameDataRecord_SameInstance_MultiThread()
    {
        Action action1 = () =>
        {
            var dal = new DataAccessManager();
            for (int i = 0; i < 10000; i++)
            {
                dal.Begin();
                dal.Current.Session.SaveOrUpdate(_configStub1);
                dal.Current.Commit();
                dal.End();
            }
        };
        Action action2 = () =>
        {
            var dal = new DataAccessManager();
            for (int i = 0; i < 10000; i++)
            {
                dal.Begin();
                dal.Current.Session.SaveOrUpdate(_configStub1);
                dal.Current.Commit();
                dal.End();
            }
        };
        var task1 = Task.Factory.StartNew(action1);
        var task2 = Task.Factory.StartNew(action2);
        task1.Wait();
        task2.Wait();
    }

测试中引用的DataAccess Manager如下：

public class DataAccessManager : IDataAccessManager
{
    private readonly ThreadLocal<ISessionManager> _current = new ThreadLocal<ISessionManager>();
    public void Begin()
    {
        Current = new SessionManager();
    }
    public ISessionManager Current
    {
        get { return _current.Value; }
        set { _current.Value = value; }
    }
    public void End(bool doComplete = true)
    {
        bool isActive = Current.Transaction != null && Current.Transaction.IsActive;
        if (doComplete && isActive) Current.Commit();
        else if (!doComplete && isActive) Current.Transaction.Rollback();
        Current.Dispose();
    }
}

SessionManager是这样的：

public class SessionManager : ISessionManager
{
    /// <summary>
    /// Initializes a new instance of the <see cref="SessionManager"/> class.
    /// </summary>
    public SessionManager()
    {
        Session = ContextFactory.OpenSession();
        Transaction = Session.BeginTransaction();
    }
    public ITransaction Transaction { get; private set; }
    public ISession Session { get; private set; }
    public void Commit()
    {
        try
        {
            Transaction.Commit();
        }
        catch (Exception ex)
        {
            Transaction.Rollback();
            throw;
        }
    }
}