JPA中的事务使用多个线程

Question

我的目标是使用单元测试在我的应用程序中激发一个乐观的锁定异常.我已经理解了如何在理论上做到这一点.但我在实践中的问题是如何在两个线程之间维护一个事务？

所以,这就是我到目前为止所做的:

我正在使用JUnit测试:

@RunWith(SpringJUnit4ClassRunner.class)

使用EntityManager org.springframework.orm.jpa.JpaTransactionManager

每个方法的定义 @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)

然后开始一个交易entityManager.getTransaction().begin();并结束entityManager.getTransaction().rollback());

这在单线程测试中运行良好,保存,更新等.

要创建多个线程,我使用Springs TaskExecutor(类似于这里所描述的: 使用TaskExecutor示例的任何好的Spring线程？)

但是我需要做些什么来维护两个线程之间的事务呢？我尝试过使用@Transactional注释run() - 方法,但这不起作用.

Answer 1

想到的几个问题 -

全局事务
您的所有线程是否应该属于同一个事务？这意味着,如果一个线程抛出异常,你想要回滚其他线程中的更改吗？

本地事务 每个线程是否应该拥有自己的事务边界而不影响其他线程？在这种情况下,一个线程中的异常和回滚不会影响其他线程.

要实现全局事务,您很可能必须使用具有适当资源驱动程序的JTA事务管理器.Spring没有对全局事务的默认支持.如果您的应用程序在Java EE应用程序服务器(Jboss,Weblogic)中运行,则默认情况下您将获得JTA支持,您可以配置spring以使用应用程序服务器的事务管理功能.如果你在tomcat中运行,你可以插入一个开源JTA实现,如 -

Atomikos公司

Jboss交易

为了实现本地事务(即每个线程都有自己的事务边界),我认为除了使用spring transactional annotations之外你不会做任何事情.在下面的示例中,只需确保'service'是一个spring bean并且doSomething()被适当地注释.

taskExecutor.execute( new Runnable() {
           public void run() {
                service.doSomething( );
           }
      });