springboot 使用ThreadPoolTaskExecutor线程池 子线程如何进行事务回滚

在Spring Boot中，使用ThreadPoolTaskExecutor线程池执行异步任务时，子线程无法直接参与到主线程的事务中，因此无法进行事务回滚。这是因为Spring事务管理是基于线程的，而子线程无法共享主线程的事务上下文。

然而，你可以通过一些技巧来实现子线程的事务回滚。一种常见的方法是使用编程式事务管理，即在子线程中手动开启事务并进行回滚操作。

下面是一个示例代码，演示了如何在子线程中进行事务回滚：

@Service
public class MyService {
    @Autowired
    private TransactionTemplate transactionTemplate;

    @Autowired
    private ThreadPoolTaskExecutor taskExecutor;

    public void doAsyncTask() {
        taskExecutor.execute(() -> {
            try {
                transactionTemplate.execute(status -> {
                    // 在子线程中执行需要事务管理的业务逻辑
                    // ...

                    // 如果发生异常，手动回滚事务
                    if (发生异常) {
                        status.setRollbackOnly();
                    }

                    return null;
                });
            } catch (Exception e) {
                // 处理异常
            }
        });
    }
}

在上述代码中，我们使用了TransactionTemplate来手动开启事务，并通过status.setRollbackOnly()方法来标记事务回滚。这样，即使在子线程中发生异常，事务也会被回滚。

需要注意的是，使用编程式事务管理需要谨慎处理事务的边界和异常处理，以确保事务的正确性和一致性。