CompletableFuture.runAsync 异步回调

CompletableFuture.runAsync 异步任务

//外派一个可能阻塞的任务，另外执行，自己先执行其他任务，后面再get回任务结果
** CompletableFuture completableFuture = CompletableFuture.supplyAsync(()->{});**

package CompleTableFutureA;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;

/**CompletableFuture.runAsync 异步任务
 * @author liu
 */
public class Demo01 {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
/*//没有返回值的runAsync 异步回调
        CompletableFuture<Void> completableFuture1 = CompletableFuture.runAsync(()->{
            try {
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName()+".runAsync==>void");
        });
        System.out.println("11111");
        completableFuture1.get();//获取阻塞执行结果*/


        //有返回值的supplyAsync 异步回调
        //ajax，成功和失败的回调
        //返回的是错误信息
        CompletableFuture<Integer> completableFuture = CompletableFuture.supplyAsync(() -> {
            System.out.println(Thread.currentThread().getName() + "supplyAsync=>Integer");
            //int i=10/0;
            return 200;
        });

        System.out.println(completableFuture.whenComplete((t, u) -> {
            System.out.println("t-> " + t);//正常的返回结果
            System.out.println("u-> " + u);//错误信息
        }).exceptionally((e) -> {
            System.out.println(e.getMessage());
            return 404;
        }).get());

    }
}