我是大白(●—●),这是我开始学习记录大白Java软件攻城狮晋升之路的第四十三天,今天学习的是【尚硅谷】大厂必备技术之JUC并发编程,该篇仅做简单介绍,具体将会在之后补上
同步和异步的通俗解释,比如需要找一个A同学,同步的话就是我在这个A同学的位置上一直等着他回来,不能干其他事情,而异步就是告诉其他一个B同学,A同学如果回来了通知我一声,我就可以干别的事情。
在java中可以使用CompletableFuture类来实现异步调用。
通过CompletableFuture类来展示
1.无返回值的异步任务
public class CompletableFutureDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException {
CompletableFuture<Void> completableFuture1 = CompletableFuture.runAsync(() -> {
System.out.println(Thread.currentThread().getName() + "completableFuture1");
});
System.out.println(completableFuture1.get());
}
}
运行结果:
2.有返回值的异步任务
public class CompletableFutureDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException {
CompletableFuture<Integer> completableFuture2 = CompletableFuture.supplyAsync(() -> {
System.out.println(Thread.currentThread().getName() + "completableFuture2");
return 1024;
});
System.out.println(completableFuture2.get());
completableFuture2.whenComplete((t,u) -> {
System.out.println("-----t=" + t); //返回值
System.out.println("-----u=" + u); //异常
}).get();
}
}
运行结果
发现u是一个null,那么他到底是什么含义呢?
查看原码分析,它是一个继承Throwable的类,查看其实现类发现都是异常,由此可知,返回的应该是异常。
public CompletableFuture<T> whenComplete(
BiConsumer<? super T, ? super Throwable> action) {
return uniWhenCompleteStage(null, action);
}
因此将代码改为
CompletableFuture<Integer> completableFuture2 = CompletableFuture.supplyAsync(() -> {
System.out.println(Thread.currentThread().getName() + "completableFuture2");
//模拟异常
int i = 1/0;
return 1024;
});
运行结果,由于笔者的运行结果和老师有出入,我就用课程的截图: