情景：

每次需要在此阻塞等待结果返回可能还会触发超时重试使得后续业务执行受到影响。下面的代码执行是串行执行，并发度低。

        long startTime = System.currentTimeMillis();
        int threadNum = 10;
        for (int i = 0; i < threadNum; i++) {
            try {
                // 每次需要在此阻塞等待结果返回 可能还会触发超时重试 使得后续业务执行受到影响
                String result = dataService.sendData("test" + i);
                System.out.println(result);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        long endTime = System.currentTimeMillis();
        System.out.println(" time cost : " + (double)((endTime - startTime)/1000) + " s");

可以使用 CompletableFuture 进行异步调用和任务编排，改写完变为异步调用，耗时短，任务调用完后会自动执行后续的业务。

        int threadNum = 10;
        long startTime = System.currentTimeMillis();
        for (int i = 0; i < threadNum; i++) {
            try {
                int finalI = i;
                CompletableFuture<String> cf = CompletableFuture.supplyAsync(()->{
                     String result = dataService.sendData("test" + finalI);
                     return  result;
                }).thenCompose(result -> CompletableFuture.supplyAsync(()->{
                    // 拿到rpc调用的结果后进行相关的操作
                    System.out.println(result);
                    return "";
                }));
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        long endTime = System.currentTimeMillis();
        System.out.println(" time cost : " + (double)((endTime - startTime)/1000) + " s");

服务端也可以进行类似的改进，通过对 CompletableFuture 的支持，RPC 框架可以真正地做到在调用端与服务端之间完全异步，同时提升了调用端与服务端的两端的单机吞吐量，并且 CompletableFuture 是Java8 原生支持，业务逻辑中没有任何代码入侵性。