天天看點

Java實作異步調用方法(jdk1.8)

點選上方“秋秋秋影影影”,并“星标置頂”

                                                                           喜歡我的都關注我了

                                                                        閱讀本文大約需要 30秒

Java實作異步調用方法(jdk1.8)

jdk1.8開始的Future

很多時候,我們需要調用一個耗時方法,但是我們并不需要等待它執行完,才繼續後面的工作,阻塞在這裡是一個非常浪費時間的事,那麼我們有沒有辦法解決呢?有!讓它異步執行!

jdk1.8中提供了

lambda

表達式,使得java向函數式語言又靠近了一步。借助jdk原生的

CompletableFuture

可以實作異步的操作,同時結合

lambada

表達式大大簡化了代碼量。代碼例子如下:

package cc.mrbird.febs.common.utils;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.function.Supplier;
/**
 * @description:
 * @author: qying
 * @time: 2020/10/26 15:28
 */
public class JavaPromise {
    public static void main(String[] args) throws Throwable, ExecutionException {
        // 兩個線程的線程池
        ExecutorService executor = Executors.newFixedThreadPool(2);
        //jdk1.8之前的實作方式
        CompletableFuture<String> future = CompletableFuture.supplyAsync(new Supplier<String>() {
            @Override
            public String get() {
                System.out.println("開始執行任務!");
                try {
                    //模拟耗時操作
                    Thread.sleep(20000);
                    System.out.println("我是一個特别耗時的任務");
                } catch (Exception e) {
                    e.printStackTrace();
                }
                return "耗時任務結束完畢!";
            }
        }, executor);

        //采用lambada的實作方式
        future.thenAccept(e -> System.out.println(e + " ok"));

        System.out.println("不等上面了,我先跑了");
    }
}
           

列印結果為:

開始執行任務!, 

不等上面了,我先跑了, 

 我是一個特别耗時的任務,

耗時任務結束完畢! ok

在模拟耗時操作的地方放我們需要執行的特别耗時的方法,而主程式已經先拿到關鍵資料傳回了,不必等到所有方法跑完再傳回