使用CompletableFuture实现异步编程

Object result1 = service1.func1();//执行80ms
Object result2  =service2.func2();//执行50ms

service3.func3(result1,result2);

class TaskService{

    public  CompletableFuture<String> findUser(){
        CompletableFuture<String> future = new CompletableFuture();
　　　　　//模仿远程调用线程
        new Thread(){

            @Override
            public void run() {

                String result = null;
                System.out.println("任务开始执行....");
                try{
                    Thread.sleep(3000);
                    //模仿RPC远程调用
                    result = rpcRequest(true);

                    System.out.println("任务执行结束....");

                }
                catch(Exception ex){
                    future.completeExceptionally(ex);
                }
                future.complete(result);
            }
        }.start();
　　　　　直接返回future.
        return future;
    }

    /**
     *功能描述
     * @author lgj
     * @Description   模仿RPC远程调用
     * @date 4/29/19
     * @param:    flag　　　true：返回正常结果  false:抛出异常
     * 　　　
     * @return:
     *
    */
    public String rpcRequest(boolean flag){
        String result = null;
        if(flag){
            result = "libai";
        }
        else {
            throw new NullPointerException();
        }
        return  result;
    }


}　　　　　

public class CompletableFutureDemo {

    public static void main(String args[]){

        TaskService service = new TaskService();

        CompletableFuture<String> future = service.findUser();

        future.whenComplete((t,u)->{

            if(u != null){
                System.out.println("异步调用发生异常:" + u);
            }
            else {
                System.out.println("异步调用执行正常: " + t);
            }


        });

        System.out.println("主线程任务执行完毕");

    }
}

 public CompletableFuture<T> whenComplete(
        BiConsumer<? super T, ? super Throwable> action) {
        return uniWhenCompleteStage(null, action);
    }

任务开始执行....
主线程任务执行完毕
任务执行结束....
异步调用执行正常: libai

任务开始执行....
主线程任务执行完毕
异步调用发生异常:java.lang.NullPointerException