如何在多线程环境中使用@Transactional

Question

我正在使用多线程执行插入操作。我使用了带注释的方法，我的方法是@Transaction注释。但我无法执行插入操作，导致出现以下异常。

异常线程"Thread-21"javax.persistence.Transaction必需异常：在org.hibernate.ejb.AbstractQueryImpl.executeUpdate（AbstractQueryImpl.java:96）在sun.reflect.NativemetodAccessorImpl.invoke0（本机方法）在sun.reflect.NativemetodAccessorImpl.invoke（NativemetodAccessorImpl.java:62）执行更新/删除查询

Answer 1

因为spring Bean是包装的，所以必须从线程调用包装的方法：

@Autowire
private final MyService ms=null;

public void removeMultithreaded(int[] userIds){
  for(int i =0; i< userIds.length; i++) {
    int userId=userIds[i];
    new Thread(()-> ms.delete(userId)).start();
  }
}

在这段代码中，您调用删除必须由@Transactional注释的内容。

请注意：您可以同时删除的用户名数量受连接池大小的限制！由于删除操作可能比从连接池中收集和释放用户更快，因此即使您必须删除的用户数量高于连接池允许的数量，您也可能永远不会遇到问题。

Answer 2

因为没有代码...为了让它工作，你必须

1. 用@Transactional注释你的delete方法，我们称之为delete
2. 该方法的调用必须从bean外部进行，以便AOP启动

所以内部调用就像

void doSomething(){
    this.delete();
}

行不通

但是

@Autowired
YourBean bean;

...
bean.delete(); 

我会做好的