java回调函数

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

public class FutureTest {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        CompletableFuture<Void> completableFuture = CompletableFuture.runAsync(
                ()->{
                    try {
                        TimeUnit.SECONDS.sleep(2);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread().getName()+
                            "【CompletableFuture.runAsync】");
                }

        );
        System.out.println("【执行main线程】");
        System.out.println("【获取回调函数结果】"+completableFuture.get());

        CompletableFuture<Integer> completableFuture1 = CompletableFuture.supplyAsync(()->{
            try {
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName()+"CompletableFuture.supplyAsync");
            return 1024;
        });
        System.out.println("执行main线程");
        System.out.println(completableFuture1.whenComplete((t, u) -> {
            System.out.println("t = " + t);
            System.out.println("u = " + u);
        }).exceptionally((e) -> {
            System.out.println("e.getMessage() = " + e.getMessage());
            return -1;
        }).get());
    }
}