java - 在spring中的事务中开启多线程，怎么捕捉异常回滚呢？

问题描述

假设我在某个事务中使用2个线程来加快处理速度，那么如果userDao.addOrg()方法抛出了RuntimeException异常，那么事务不会回滚，也捕获不到错误，那应该怎么做才对呢？

ExecutorService executorService = Executors.newCachedThreadPool();@Transactional(rollbackFor=Throwable.class)public void add(){CountDownLatch cdl = new CountDownLatch(2);executorService.submit(new Runnable() {public void run() { userDao.addOrg(); //抛出RuntimeException异常cdl.countDown(); }});executorService.submit(new Runnable() {public void run() { userDao.addSystem(); cdl.countDown(); }});cdl.wait(10,TimeUnit.SECONDS);}

问题解答

@Transactional只能控制单线程事务，所以子线程是不受add方法上的事务控制的。你可以在子线程调用的方法上开启新事务，进行回滚。

开启子线程调用受事务控制的方法：

executorService.submit(new Runnable() {public void run() { addOperation.addMethod(); }});

@Componentclass AddOperation{ @Transactional public addMethod(){ userDao.addOrg(); //抛出RuntimeException异常 cdl.countDown(); }}

注意，@Transactional是通过proxy实现的，所以addMethod要置于新类AddOperation中，不能放到add方法所在的类。