|
将completableFutureTask方法变为 void 类型
- @Async
- public void completableFutureTask(String start) {
- ......
- //这里可能是系统对任务执行结果的处理，比如存入到数据库等等......
- //doSomeThingWithResults(results);
- }
Controller 代码修改如下：
- @GetMapping("/movies")
- public String completableFutureTask() throws ExecutionException, InterruptedException {
- // Start the clock
- long start = System.currentTimeMillis();
- // Kick of multiple, asynchronous lookups
- List<String> words = Arrays.asList("F", "T", "S", "Z", "J", "C");
- words.stream()
- .forEach(word -> asyncService.completableFutureTask(word));
- // Wait until they are all done
- // Print results, including elapsed time
- System.out.println("Elapsed time: " + (System.currentTimeMillis() - start));
- return "Done";
- }
请求这个接口，控制台打印出下面的内容：
- Elapsed time: 0
- 2019-10-01 14:02:44.052 WARN 19051 --- [lTaskExecutor-4] g.j.a.service.AsyncService : My ThreadPoolTaskExecutor-4start this task!
- 2019-10-01 14:02:44.052 WARN 19051 --- [lTaskExecutor-3] g.j.a.service.AsyncService : My ThreadPoolTaskExecutor-3start this task!
- 2019-10-01 14:02:44.052 WARN 19051 --- [lTaskExecutor-2] g.j.a.service.AsyncService : My ThreadPoolTaskExecutor-2start this task!
- 2019-10-01 14:02:44.052 WARN 19051 --- [lTaskExecutor-1] g.j.a.service.AsyncService : My ThreadPoolTaskExecutor-1start this task!
- 2019-10-01 14:02:44.052 WARN 19051 --- [lTaskExecutor-6] g.j.a.service.AsyncService : My ThreadPoolTaskExecutor-6start this task!
- 2019-10-01 14:02:44.052 WARN 19051 --- [lTaskExecutor-5] g.j.a.service.AsyncService : My ThreadPoolTaskExecutor-5start this task!
可以看到系统会直接返回给用户结果，然后系统才真正开始执行任务。
待办
- Future vs. CompletableFuture
- 源代码分析
（编辑：西安站长网）
【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!
|
