package completable;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class CompletableFutureDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException {
//异步调用,没有返回值
CompletableFuture<Void> completableFuture1 = CompletableFuture.runAsync(()->{
System.out.println(Thread.currentThread().getName()+"completableFuture1");
});
completableFuture1.get();
//异步调用,有返回值
CompletableFuture<Integer> completableFuture2 = CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread().getName()+"completableFuture1");
return 1024;
});
completableFuture2.whenComplete((t, u)->{
System.out.println("----t="+t); //返回值
System.out.println("----u="+u); //异常
}).get();
}
}
总结来说,就是用CompleTableFuture类的runAsync和supplyAsync方法。