将Spring Transaction与多个线程一起使用[重复]

Question

这个问题我已经被问过很多次了，而且一直困扰着我。

我们有一个服务类，有3个DAO方法更新3个不同的表。这种设计使得对所有三个表的更新都应该是原子的。我有3个线程分别调用我的服务类，对于每个DAO方法更新，如何使用Spring事务或任何事务管理器将所有线程（操作）保持在单个事务下？？有任何关于文档的想法或指针吗？？谢谢

Answer 1

这可以通过将事务保持在线程级别来实现。但是，u 需要在所有这些线程之间共享一个对象。此共享对象将跟踪所有这些线程的状态，并在其中任何一个线程失败时通知它们。如果此线程收到失败通知，它们本身可以引发异常，并且它们的事务将被回滚。

单个线程中的代码

    @Transactional(rollbackFor = Exception.class)
    public void saveData(Product product, ProductStatusObject productStatusObject) throws Exception {
        productDao.persist(product);
        if(product.getId() == 5) {
            productStatusObject.updateCounter(false);
        } else {
            productStatusObject.updateCounter(true);
        }
        if(!productStatusObject.getStatus()) {
            throw new Exception();
        }
    }

共享类中的代码

    private final int  totalThreads;

    private int executedThreads = 0;
    private Boolean finalStatus = true;
    
    public ProductStatusObject(int totalThreads) {
        this.totalThreads = totalThreads;
    }
    
    public synchronized void updateCounter(Boolean threadStatus) throws InterruptedException {
        executedThreads ++;
        if(!threadStatus) {
            this.finalStatus = false;
        }
        if(totalThreads == executedThreads) {
            notifyAll();
        } else {
            wait();
        }
        
    }
    
    public synchronized Boolean getStatus() {
        return finalStatus;
    }

这里的失败条件是，如果任何线程保存id为5的数据，所有线程都将回滚它们的代码。否则一切都会成功

Answer 2

服务方法应该是开始交易的方法

服务方式

public class Service{
// define dao1,dao2,dao3
@Transactional
public someMethod(){
   dao1.someUpdate();
   dao2.someUpdate();
   dao3.someUpdate();
}
}

Dao1.class

 public class Dao1{

      @Transactional (propagation = Propagation.MANDATORY)
      public someUpdate(){

      }
    }

类似地，Dao2和Dao3

一些更新（）将使用由Service.class的一些方法（）启动的事务