JUC并发编程学习笔记（十四）异步回调

异步回调

Future设计的初衷：对将来的某个事件的结果进行建模

在Future类的子类中可以找到CompletableFuture，在介绍中可以看到这是为非异步的请求使用一些异步的方法来处理


点进具体实现类中，查看方法，可以看到CompletableFuture中的异步内部类，里面是实现的异步方法

以及一些异步方法

通过CompletableFuture可以实现与Ajax一样的异步调用。

1. package org.example.asyn;
3. import java.util.concurrent.CompletableFuture;
4. import java.util.concurrent.ExecutionException;
5. import java.util.concurrent.TimeUnit;
7. /*
8. * 异步调用：CompletableFuture
9. * //异步执行
10. * //成功回调
11. * //失败回调
12. * */
13. public class Demo01 {
14.     public static void main(String[] args) throws ExecutionException, InterruptedException {
15.         CompletableHasReturn() ;
17.     }
19.     public static void CompletableNotReturn() throws ExecutionException, InterruptedException {
20.         //没有返回值的异步回调
21.         CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
23.             try {
24.                 TimeUnit.SECONDS.sleep(3);
25.             } catch (InterruptedException e) {
26.                 throw new RuntimeException(e);
27.             }
28.             System.out.println("执行异步请求完毕");
30.         });
33.         for (int i = 0; i < 5; i++) {
35.             TimeUnit.SECONDS.sleep(1);
36.             System.out.println(i);
39.         }
40.         //获取回调结果
41.         future.get();
42.     }
44.     public static void CompletableHasReturn() throws ExecutionException, InterruptedException {
45.         //有返回值的异步回调
46.         CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
47.             int i = 10/0;
48.             return 1024;
49.         });
50.         System.out.println(future.whenComplete((t, u) -> {//编译
51.             System.out.println("t:" + t);//t是正常的返回结果
52.             System.out.println("u:" + u);//u是报错信息
53.         }).exceptionally((e) -> {//编译异常 /Exception e
54.             e.printStackTrace();
55.             return 123;//异常返回结果
56.         }).get());//获取回调结果
57.     }
58. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！