使用springboot，如何在异步方法中访问存储库？

Question

我正在尝试在从CrudRepository扩展的存储库接口上执行.findAll（）。我试图在@Async方法中使用存储库的@Autowire实现来执行此操作。当我运行以下代码时，@Async线程在 UpdateTasksService List 中永久等待

当我从updateTasks（）方法中删除@Async注释时，程序将按预期运行并打印所有.toString（）数据。

我的问题是:

1. 为什么我不能在@Async方法中使用@Autow的TaskRepository taskRepo；？
2. 如何在@Async方法中使用存储库？

提前感谢您！

计划组件

@Component
public class ScheduleComponent {

    @Autowired
    UpdateTasksService updateTasks;

    @PostConstruct
    public void update(){
        Future<Void> updateTasksFuture = updateTasks.updateTasks();
        try {
            updateTasksFuture.get();
            System.out.println("Done");
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }
}

UpdateTaskService

@Service
public class UpdateTasksService {

    @Autowired
    TaskRepository taskRepo;

    @Async
    public Future<Void> updateTasks() {
        System.out.println("The method starts");
        List<Task> tasks = (List<Task>)taskRepo.findAll();
        for(Task task: tasks){
            System.out.println(task.toString());
        }
        return new AsyncResult<Void>(null);
    }
}

任务库

@Repository
public interface TaskRepository extends CrudRepository<Task, String> {
}




Answer 1

我遇到了同样的问题，并注意到当查询基于JDBC API（而不是JPA存储库）或在SpringData存储库中使用@Query定义查询时不会发生这种行为。作为一种解决方法，我在PostConstruct中的一个存储库上调用了刷新。我仍然不知道为什么会发生这种情况。

解决方法：

 @Service
    public class UpdateTasksService {
    
        @Autowired
        TaskRepository taskRepo;
        
         @PostConstruct
        public void init() {
            //Workaround to a async method that waits forever when called  
            //from PostConstruct from another component
            taskRepo.flush();
        }
    
        @Async
        public Future<Void> updateTasks() {
            System.out.println("The method starts");
            List<Task> tasks = (List<Task>)taskRepo.findAll();
            for(Task task: tasks){
                System.out.println(task.toString());
            }
            return new AsyncResult<Void>(null);
        }
    }