java - ExecutorService 中对 MongoRepository 的调用无法完成

Question

我正在运行 Spring Boot 应用程序，并且有多个线程调用 MongoRepository。然而，这会导致奇怪的超时行为。

这是我的 MongoRepository:

public interface EquipmentRepository extends MongoRepository<Equipment, String> {

    Optional<Equipment> findByEquipmentSerialNumber(String equipmentSerialNumber);

}

这是我的代码的简化版本，突出显示了问题

ExecutorService taskExecutor = Executors.newFixedThreadPool(4);
taskExecutor.execute(() -> {
    LOG.info("Executing query...");
    Optional<Equipment> equipment = equipmentRepository.findByEquipmentSerialNumber("21133"); // guaranteed to be found
    LOG.info("Query done: {}", equipment.get().getEquipmentSerialNumber());
});
taskExecutor.shutdown();
LOG.info("taskExecutor shut down");
try {
    taskExecutor.awaitTermination(30, TimeUnit.SECONDS);
    LOG.info("taskExecutor done");
} catch (InterruptedException e) {
    System.out.println("Error");
}

产生的输出如下所示

taskExecutor shut down
Executing query...
<30 second pause>
taskExecutor done
Query done: 21133

如果我增加awaitTermination()的超时时间，暂停也会相应增加。因此，不知何故，我的execute() lambda中的代码被“暂停”，并且仅在达到超时后才继续。

如果我删除对 EquipmentRepository 的调用，一切都会按预期运行，并且不会出现 30 秒的暂停。

是什么导致我的代码无法在未达到超时的情况下完成？

Answer 1

看起来 mongo 存储库等待“主”线程执行查询(虽然很奇怪)

不回答您的具体问题，但可能解决您的问题:Spring Data can do async requests doc