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

编程问答 2022-04-29

问题描述

我正在尝试在从 CrudRepository 扩展的存储库接口上执行 .findAll()。我正在尝试使用存储库的 @Async 实现在 @Autowire 方法中执行此操作。当我运行以下代码时，@Async 线程在 UpdateTasksService 处永远等待 List<Task> tasks = (List<Task>)taskRepo.findAll();

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

我的问题是：

  1. 为什么我不能在 @Autowired TaskRepository taskRepo; 方法中使用 @Async？
  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();
        }
    }
}

更新任务服务

@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> {
}

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

hibernatejavajavajpajpaspring-boot