JDK1.8提供的异步执行CompletableFuture类

首先什么是CompletableFuture：
在Java 8中, 新增加了一个包含50个方法左右的类: CompletableFuture，结合了Future的优点，提供了非常强大的Future的扩展功能，可以帮助我们简化异步编程的复杂性，提供了函数式编程的能力，可以通过回调的方式处理计算结果，并且提供了转换和组合CompletableFuture的方法。

CompletableFuture被设计在Java中进行异步编程。异步编程意味着在主线程之外创建一个独立的线程，与主线程分隔开，并在上面运行一个非阻塞的任务，然后通知主线程进展，成功或者失败。

通过这种方式，你的主线程不用为了任务的完成而阻塞/等待，你可以用主线程去并行执行其他的任务。 使用这种并行方式，极大地提升了程序的表现。

提供一个实现的Demo，
其中supplyAsync()方法是有返回值的，
runAsync()方法是没有返回值的。

package com.itheima;

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

public class CompletableFutureDemo {
    public static void main(String[] args) throws Exception {
        //异步任务一   5s
        CompletableFuture num1 = CompletableFuture.supplyAsync(() -> {
            Random random = new Random();
            int i = random.nextInt(10);
            System.out.println(new Date() + " : " + Thread.currentThread().getName() + " : 任务一执行, 执行耗时 :" + i + "s");
            try {
                TimeUnit.SECONDS.sleep(i);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return i;
        });

        //异步任务二   2s
        CompletableFuture num2 = CompletableFuture.supplyAsync(() -> {
            Random random = new Random();
            int i = random.nextInt(10);
            System.out.println(new Date() + " : " + Thread.currentThread().getName() + " : 任务二执行, 执行耗时 :" + i + "s");
            try {
                TimeUnit.SECONDS.sleep(i);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return i;
        });


        //异步任务三   3s
        CompletableFuture num3 = CompletableFuture.supplyAsync(() -> {
            Random random = new Random();
            int i = random.nextInt(10);
            System.out.println(new Date() + " : " + Thread.currentThread().getName() + " : 任务三执行, 执行耗时 :" + i + "s");
            try {
                TimeUnit.SECONDS.sleep(i);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return i;
        });


 
        CompletableFuture.allOf(num1,num2,num3).join();

        int result = num1.get() + num2.get() + num3.get();
        System.out.println(new Date()+"最终的运行结果: "+ result); //10s , 5s
    }
}