CompletableFuture接口核心方法介绍

CompletableFuture 可以看做是futuretask接口的升级版

获取对象,用这四个方法:

runAsync(Runnable runnable,Executor executor) ;
runAsync(Runnable runnable);
supplyAsync(Supplier<U> supplier);
supplyAsync(Supplier<U> supplier, Executor executor)

Demo:

ExecutorService executorService = Executors.newFixedThreadPool(3);
        /**
         * 无返回值的构造
         */
        CompletableFuture<Void> voidCompletableFuture = CompletableFuture.runAsync(() -> {
            System.out.println(Thread.currentThread().getName()+"无返回值");
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
        }, executorService);

        try {
            TimeUnit.SECONDS.sleep(1);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }


        /**
         * 创建有返回值的
         */


        CompletableFuture<String> uCompletableFuture = CompletableFuture.supplyAsync(() -> {

            System.out.println(Thread.currentThread().getName() +"有返回值");
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }

            return "hello supplier";
        }, executorService);

        System.out.println(voidCompletableFuture.get());
        System.out.println(uCompletableFuture.get());

        executorService.shutdown();