springboot 异步回调

定义异步方法，使用Future<T>来返回异步调用的结果 @Async public Future<String> firstTask() throws InterruptedException { System.out.println(“开始做任务一”); long start = System.currentTimeMillis(); Thread.sleep(random.nextInt(10000)); long end = System.currentTimeMillis(); System.out.println(“完成任务一，当前线程：” + Thread.currentThread().getName() + “，耗时：” + (end - start) + “毫秒”); return new AsyncResult<>(“任务一完成”); } @Async public Future<String> secondTask() throws InterruptedException { System.out.println(“开始做任务二”); long start = System.currentTimeMillis(); Thread.sleep(random.nextInt(10000)); long end = System.currentTimeMillis(); System.out.println(“完成任务二，当前线程：” + Thread.currentThread().getName() + “，耗时：” + (end - start) + “毫秒”); return new AsyncResult<>(“任务二完成”); } @Async public Future<String> thirdTask() throws InterruptedException { System.out.println(“开始做任务三”); long start = System.currentTimeMillis(); Thread.sleep(random.nextInt(10000)); long end = System.currentTimeMillis(); System.out.println(“完成任务三，当前线程：” + Thread.currentThread().getName() + “，耗时：” + (end - start) + “毫秒”); return new AsyncResult<>(“任务三完成”); }调用@GetMapping(“test-future”) public void testFuture() { try { Future<String> result1 = asyncService.firstTask(); Future<String> result2 = asyncService.secondTask(); Future<String> result3 = asyncService.thirdTask(); while (true) { if (result1.isDone() && result2.isDone() && result3.isDone()) { System.out.println(“执行异步回调”); break; } } System.out.println(“异步回调结束”); } catch (InterruptedException e) { e.printStackTrace(); } }调用结果开始做任务一开始做任务二开始做任务三完成任务二，当前线程：task-2，耗时：896毫秒完成任务一，当前线程：task-1，耗时：7448毫秒完成任务三，当前线程：task-3，耗时：7901毫秒执行异步回调异步回调结束代码：异步回调