SpringBoot多線程事務回滾

    public String test() {
        String result = "";
        CountDownLatch rollBackLatch = new CountDownLatch(1);
        CountDownLatch mainThreadLatch = new CountDownLatch(2);
        AtomicBoolean rollbackFlag = new AtomicBoolean(false);
        List<Future<String>> list = new ArrayList<Future<String>>();
        // 線程有返回值
        Future<String> future = executor1(rollBackLatch, mainThreadLatch, rollbackFlag);
        list.add(future);
        // 線程無返回值
        executor2(rollBackLatch, mainThreadLatch, rollbackFlag);
        // 主線程業務執行完畢 如果其他線程也執行完畢 且沒有報異常 正在阻塞狀態中 喚醒其他線程 提交所有的事務
        // 如果其他線程或者主線程報錯 則不會進入if 會觸發回滾
        if (!rollbackFlag.get()) {
            try {
                mainThreadLatch.await();
                rollBackLatch.countDown();
                for (Future<String> f : list)
                    if (!"success".equals(f.get()))
                        result = f.get() + "。";
            } catch (InterruptedException | ExecutionException e) {
                e.printStackTrace();
            }
        }
        return result;
    }

    @Autowired
    private PlatformTransactionManager transactionManager;

    public Future<String> executor1(CountDownLatch rollBackLatch, CountDownLatch mainThreadLatch,
            AtomicBoolean rollbackFlag) {
        ExecutorService executor = Executors.newCachedThreadPool();
        Future<String> result = executor.submit(new Callable<String>() {

            @Override
            public String call() throws Exception {
                if (rollbackFlag.get())
                    return "error"; // 如果其他線程已經報錯 就停止線程
                // 設置一個事務
                DefaultTransactionDefinition def = new DefaultTransactionDefinition();
                def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW); // 事物隔離級別，開啟新事務，這樣會比較安全些。
                TransactionStatus status = transactionManager.getTransaction(def); // 獲得事務狀態
                try {
                    // 業務處理開始
                    // ..............
                    // 業務處理結束
                    mainThreadLatch.countDown();
                    rollBackLatch.await();// 線程等待
                    if (rollbackFlag.get()) {
                        transactionManager.rollback(status);
                    } else {
                        transactionManager.commit(status);
                    }
                    return "success";
                } catch (Exception e) {
                    e.printStackTrace();
                    // 如果出錯了 就放開鎖 讓別的線程進入提交/回滾 本線程進行回滾
                    rollbackFlag.set(true);
                    rollBackLatch.countDown();
                    mainThreadLatch.countDown();
                    transactionManager.rollback(status);
                    return "操作失敗：" + e.getMessage();
                }
            }

        });
        // result.get()阻塞線程
        return result;
    }

    public void executor2(CountDownLatch rollBackLatch, CountDownLatch mainThreadLatch, AtomicBoolean rollbackFlag) {
        ExecutorService executorService = Executors.newCachedThreadPool();
        executorService.execute(new Runnable() {

            @Override
            public void run() {
                if (rollbackFlag.get())
                    return; // 如果其他線程已經報錯 就停止線程
                // 設置一個事務
                DefaultTransactionDefinition def = new DefaultTransactionDefinition();
                def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW); // 事物隔離級別，開啟新事務，這樣會比較安全些。
                TransactionStatus status = transactionManager.getTransaction(def); // 獲得事務狀態
                try {
                    // 業務處理開始
                    // .....
                    // 業務處理結束
                    mainThreadLatch.countDown();
                    rollBackLatch.await();// 線程等待
                    if (rollbackFlag.get()) {
                        transactionManager.rollback(status);
                    } else {
                        transactionManager.commit(status);
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                    // 如果出錯了 就放開鎖 讓別的線程進入提交/回滾 本線程進行回滾
                    rollbackFlag.set(true);
                    rollBackLatch.countDown();
                    mainThreadLatch.countDown();
                    transactionManager.rollback(status);
                }
            }
        });
    }