Hibernate在不同线程运行时不必要创建新实体的问题

听起来你遇到了典型的EntityManager线程隔离+事务可见性导致的反直觉问题，我来帮你拆解原因和解决办法：

问题核心原因 #

你的测试场景里有两个关键因素触发了重复创建实体的行为：

1. EntityManager的线程绑定特性：Spring默认的EntityManager是ThreadLocal作用域的——每个线程拥有独立的EntityManager实例。主线程里jobRepository.save()后，Job实体是被主线程的EntityManager托管的，但传到子线程后，它就变成了游离态实体（脱离了原EntityManager的管理）。
2. 测试事务的延迟提交：默认情况下，Spring的@Test方法如果带有@Transactional注解，整个测试方法会被包裹在一个事务里，直到测试结束才会提交。这意味着子线程执行时，主线程保存的Job还没真正写入数据库，子线程的EntityManager查询不到这条记录，当你尝试在子线程中操作这个游离态Job时，Hibernate会认为这是一个全新的实体，从而执行插入操作。

具体解决方案 #

根据你的测试场景，推荐以下几种可行的解决方式：

1. 让主线程的保存操作立即提交事务 #

把保存Job的逻辑抽离到一个单独的方法，并用@Transactional(propagation = Propagation.REQUIRES_NEW)注解，强制这个方法在独立的事务中执行并立即提交：

@Service
public class JobService {
    @Autowired
    private JobRepository jobRepository;

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public Job saveJobImmediately() {
        return jobRepository.save(new Job());
    }
}

然后在测试中调用这个方法，这样主线程保存的Job会立即写入数据库，子线程就能查询到对应的实体，不会重复创建。

2. 子线程中通过ID查询实体而非直接使用游离态对象 #

即使主线程的事务还没提交（如果测试必须保持事务），也可以在子线程中通过jobRepository.findById(origJobID)来获取实体——不过这里要注意，如果主线程事务未提交，子线程查询不到数据，所以还是需要结合第一种方法确保数据已持久化到数据库。修改子线程逻辑：

Future<?> wait = executor.submit(() -> {
    try {
        Thread.sleep(100);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    // 改为通过ID查询，而非直接使用主线程的游离态Job对象
    Job existingJob = jobRepository.findById(origJobID).orElseThrow();
    // 对existingJob进行操作
    jobRepository.save(existingJob);
});

3. 移除测试方法的@Transactional注解 #

如果你的测试不需要事务回滚的特性，可以直接去掉测试方法上的@Transactional，这样jobRepository.save()会立即提交到数据库，子线程就能看到这条数据。

额外注意事项 #

• 记得在测试结束后关闭线程池，避免资源泄漏：executor.shutdown(); executor.awaitTermination(1, TimeUnit.MINUTES);
• EntityManager不是线程安全的，绝对不要在多线程之间共享同一个EntityManager实例，这会导致不可预测的问题。

内容的提问来源于stack exchange，提问作者echen