Java使用FutureTask實(shí)現(xiàn)預(yù)加載的示例詳解

更新時(shí)間：2023年06月20日 11:45:50 作者：海塔燈

基于FutureTask的特性，通?？梢允褂肍utureTask做一些預(yù)加載工作，比如一些時(shí)間較長(zhǎng)的計(jì)算等，本文就來(lái)和大家講講具體實(shí)現(xiàn)方法吧，感興趣的可以了解一下

FutureTask介紹

FutureTask也可以用作閉鎖；FutureTask的計(jì)算是通過(guò)Callable來(lái)實(shí)現(xiàn)的，相當(dāng)于一種可生成結(jié)果的Runnable，并且可以處于3種狀態(tài)，分別是等待運(yùn)行（waiting to run）、正在運(yùn)行(Running)、和運(yùn)行完成(Completed),而運(yùn)行完成表示計(jì)算的所有可能結(jié)束方式，包括正常結(jié)束，由于取消而結(jié)束和由于異常而結(jié)束等，當(dāng)FutureTask進(jìn)入完成狀態(tài)后，它就會(huì)永遠(yuǎn)停止在這個(gè)狀態(tài)上。我們可以使用Future.get()方法獲取任務(wù)執(zhí)行的狀態(tài)。

使用場(chǎng)景

Future.get的行為取決于任務(wù)的狀態(tài)，如果任務(wù)已經(jīng)完成，那么get會(huì)立即返回結(jié)果，否則get方法將阻塞直到任務(wù)進(jìn)入完成狀態(tài)，然后返回結(jié)果或者拋出異常，F(xiàn)utureTask將計(jì)算結(jié)果從執(zhí)行計(jì)算的線程傳遞到獲取這個(gè)結(jié)果的線程，而FutureTask的規(guī)范確保了這種傳遞過(guò)程能實(shí)現(xiàn)結(jié)果的正確性

基于FutureTask的特性，通?？梢允褂肍utureTask做一些預(yù)加載工作，比如一些時(shí)間較長(zhǎng)的計(jì)算，這些計(jì)算可以在使用計(jì)算結(jié)果之前啟動(dòng)，并且計(jì)算的結(jié)果將在稍后是同，通過(guò)提前啟動(dòng)計(jì)算，可以減少等待結(jié)果時(shí)需要的時(shí)間

實(shí)例解析

假設(shè)我們要加載一個(gè)產(chǎn)品信息，使用FutureTask來(lái)執(zhí)行一個(gè)高開(kāi)銷(xiāo)的計(jì)算。代碼如下所示：首先簡(jiǎn)單寫(xiě)一個(gè)產(chǎn)品的Bean類(lèi)：

    static class ProductInfo {
        public ProductInfo(String name, String order_id) {
            this.name = name;
            this.order_id = order_id;
        }
        private String name;
        private String order_id;
        @Override
        public String toString() {
            return "ProductInfo{" +
                    "name='" + name + '\'' +
                    ", order_id='" + order_id + '\'' +
                    '}';
        }
    }

然后使用FutureTask實(shí)現(xiàn)一個(gè)產(chǎn)品信息預(yù)加載功能：

    static class Preloader {
        public void start() {
            thread.start();
        }
        private final FutureTask<ProductInfo> futureTask =
                new FutureTask<>(new Callable<ProductInfo>() {
                    @Override
                    public ProductInfo call() throws Exception {
                        return loadProductInfo();
                    }
                });
        public ProductInfo get() throws ExecutionException, 
        InterruptedException {
            return futureTask.get();
        }
        private final Thread thread = new Thread(futureTask);
        private ProductInfo loadProductInfo() {
            try {
                Thread.sleep(5000);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            return new ProductInfo("衣服", "9527");
        }
    }

驗(yàn)證代碼：

    Preloader preloader = new Preloader();
        preloader.start();
        System.out.println("start get product info before"
         + System.currentTimeMillis() / 1000);
        ProductInfo productInfo = null;
        try {
            productInfo = preloader.get();
        } catch (ExecutionException | InterruptedException e) {
            throw new RuntimeException(e);
        }
        System.out.println("start get product info afte" 
        +System.currentTimeMillis() / 1000);
        System.out.println("productInfo: " + productInfo);

如上面的代碼所示：Preloader創(chuàng)建了一個(gè)FutureTask,其中包含了加載產(chǎn)品信息的任務(wù)，以及一個(gè)執(zhí)行運(yùn)算的線程。我們?cè)黾恿艘粋€(gè) Thread.sleep(5000);模擬加載耗時(shí)。由于在構(gòu)造函數(shù)或者靜態(tài)初始化方法中啟動(dòng)線程不是一種好方法，所以提供了一個(gè)start方法來(lái)啟動(dòng)線程，當(dāng)程序后面需要ProductInfo結(jié)果時(shí)，可以調(diào)用Preloader提供的get方法，如果數(shù)據(jù)已經(jīng)加載，那么會(huì)返回這些數(shù)據(jù)，否則將等待加載完成后再返回。

到此這篇關(guān)于Java使用FutureTask實(shí)現(xiàn)預(yù)加載的示例詳解的文章就介紹到這了,更多相關(guān)Java FutureTask預(yù)加載內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: