spring多线程使用同一个事务

DataSource dataSource = transactionManager.getDataSource();
// 开启主线程事务
TransactionStatus status = transactionManager.getTransaction(null);
Future<?> future = executorService.submit(() -> {
    // 获取主线程事务信息
    Object transaction = ((DefaultTransactionStatus) status).getTransaction();
    try {
        // 通过反射获取主线程数据库连接对象
        Field field = transaction.getClass().getSuperclass().getDeclaredField("connectionHolder");
        field.setAccessible(true);
        Object object = field.get(transaction);
        // 把主线程的数据库连接绑定到子线程ThreadLocalMap中
        TransactionSynchronizationManager.bindResource(dataSource, object);
    } catch (Exception e) {
        throw new RuntimeException(e);
    }
    // 开启子线程数据库事务.因上面的绑定操作,子线程和主线程使用的是同一个数据库连接,所以所有线程的数据库操作是在同一事务中
    transactionManager.getTransaction(null);
    // 执行数据库操作

    // 清理资源（等待事务提交/回滚后）
    TransactionSynchronizationManager.unbindResource(Objects.requireNonNull(transactionManager.getDataSource()));
    TransactionSynchronizationManager.clear();
});
future.get();

// 执行数据库操作

//手动提交或回滚
transactionManager.rollback(status);