java - 使用 JPA 线程保存实体(同步)

Question

我正在使用 JAVA 中的线程对同一实体执行一些操作。当我执行 persist 方法时，问题就出现了。我这样做的方式是下一个:

@Transactional
    private void persist(){
        synchronized(this){
            JPA.em().getTransaction().begin();
            <nameObject>.save();
            JPA.em().getTransaction().commit();
        }
    }

其中 nameObject 是要保留的对象的名称。显示的错误是:

Exception in thread "Thread-38" javax.persistence.PersistenceException: org.hibernate.HibernateException: Illegal attempt to associate a collection with two open sessions
    at org.hibernate.ejb.AbstractEntityManagerImpl.convert(AbstractEntityManagerImpl.java:1389)
    at org.hibernate.ejb.AbstractEntityManagerImpl.convert(AbstractEntityManagerImpl.java:1317)
    at org.hibernate.ejb.AbstractEntityManagerImpl.convert(AbstractEntityManagerImpl.java:1323)
    at org.hibernate.ejb.AbstractEntityManagerImpl.persist(AbstractEntityManagerImpl.java:845)
    at play.db.jpa.JPABase._save(JPABase.java:31)
    at play.db.jpa.GenericModel.save(GenericModel.java:204)
    at models.invoicing.PreInvoiceThread.persist(PreInvoiceThread.java:290)
    at models.invoicing.PreInvoiceThread.run(PreInvoiceThread.java:273)
    at java.lang.Thread.run(Thread.java:745)

我尝试对对象进行锁定乐观，但没有结果。

Answer 1

您将该方法标记为事务性，同时您在保存之前开始事务，这导致打开两个 session 将代码更改为，

@Transactional
private void persist(){
    synchronized(this){
        <nameObject>.save();
    }
}

或

private void persist(){
    synchronized(this){
        JPA.em().getTransaction().begin();
        <nameObject>.save();
        JPA.em().getTransaction().commit();
    }
}