JPA中的事务使用多个线程

我的目标是使用unit testing在我的应用程序中激发一个乐观的锁定exception。 我已经理解了如何在理论上做到这一点。 但我在实践中的问题是如何在两个线程之间维护一个事务?

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

我正在使用JUnit测试:

@RunWith(SpringJUnit4ClassRunner.class) 

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

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

并使用entityManager.getTransaction().begin();启动事务entityManager.getTransaction().begin(); 并以entityManager.getTransaction().rollback());结束entityManager.getTransaction().rollback());

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

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

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

想到的几个问题 –

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

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

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

Atomikos公司

Jboss交易

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

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