wujian_csdn_csdn的博客

项目需要实现操作异步调用，直接上代码：@ApiOperation("执行操作")@PutMapping("/xxxx")public ResultBody approval(@RequestBody @Validated Param param) { try { //逻辑处理 .... Future<Object> result = this.service.do(param); //阻塞上面的方法执行，时间不超过2秒

1、FutureFuture模式是多线程设计常用的一种设计模式。Future模式可以理解成：我有一个任务，提交给了Future，Future替我完成这个任务。期间我自己可以去做任何想做的事情。一段时间之后，我就便可以从Future那儿取出结果。Future提供了三种功能：判断任务是否完成能够中断任务能够获取任务执行的结果向线程池中提交任务的submit方法不是阻塞方法，而Future.get方法是一个阻塞方法，当submit提交多个任务时，只有所有任务都完成后，才能使用get按照任务的提交顺序得

代码例子： public static void main(String[] args) throws Exception{ int count = 10; List<Thread> workers = new ArrayList<>(); for(int i = 0; i < count; i++) { final int s = i; Thread worker = new

使用多线程将库存信息同步到Elasticsearch缓存里，代码如下： @GetMapping("/internal/unifiedInventory/sync/dbToEs") public void syncUnifiedInventoryDbToEs() { ExecutorService executors = Executors.newFixedThreadPo...