java J.U.C中FutureTask的使用分析

本篇文章給大家分享的是有關(guān)java J.U.C中FutureTask的使用分析，小編覺(jué)得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說(shuō)，跟著小編一起來(lái)看看吧。

FutureTask是J.U.C里面的，但是它不是AQS的子類，但是這個(gè)類對(duì)線程結(jié)果的處理很值得我們學(xué)習(xí)和在項(xiàng)目中使用。

創(chuàng)建一個(gè)線程通常有兩種方式，一種是直接繼承Thread、另一種是直接實(shí)現(xiàn)Runnable，這兩種方式有一個(gè)共同的缺陷就是在執(zhí)行完任務(wù)之后無(wú)法獲取執(zhí)行結(jié)果。從java1.5開(kāi)始就提供了Callable和Future，通過(guò)他們可以在任務(wù)完成之后得到任務(wù)的執(zhí)行結(jié)果。

Callable與Runnable對(duì)比

• Runnable接口代碼簡(jiǎn)單，只有一個(gè)方法run()

• Callable是一個(gè)泛型接口，有一個(gè)call函數(shù)，call的返回類型就是創(chuàng)建Callable的類型，功能更強(qiáng)大一些。

Future接口

對(duì)于一個(gè)具體的Callable和Runnable任務(wù)，F(xiàn)uture可以進(jìn)行取消、查詢一個(gè)任務(wù)是否被取消、查詢是否完成、獲取結(jié)果等等。通常線程都是異步執(zhí)行的，因此不可能從其他線程中得到返回值。Future可以監(jiān)視目標(biāo)線程call的情況，當(dāng)調(diào)用Future的get()時(shí)就可以獲得它的結(jié)果，這時(shí)線程可能不會(huì)直接完成，當(dāng)前線程開(kāi)始阻塞，直到call方法結(jié)束并返回結(jié)果，線程才繼續(xù)執(zhí)行?？偨Y(jié)一句話，F(xiàn)uture可以得到其他線程任務(wù)方法的結(jié)果返回值。

FutureTask類

FutureTask類的父類是RunnableFuture，而RunnableFuture繼承了Runnable和Future兩個(gè)接口。由此可以知道FutureTask最終也是執(zhí)行Callable類型的任務(wù)。如果構(gòu)造函數(shù)參數(shù)是Runnable的話，會(huì)自動(dòng)轉(zhuǎn)換成Callable類型。FutureTask實(shí)現(xiàn)了兩個(gè)接口（Runnable和Future），所以它既可以作為Runnable被線程執(zhí)行，又可以作為Future得到Callable的返回值。RunnableFuture繼承了Runnable接口和Future接口，而FutureTask實(shí)現(xiàn)了RunnableFuture接口。

那么，這個(gè)組合的使用有什么好處呢？假設(shè)有一個(gè)很費(fèi)時(shí)的邏輯，需要計(jì)算并返回計(jì)算結(jié)果，同時(shí)這個(gè)值不是馬上需要，那么就可以使用這個(gè)組合，用另外一個(gè)線程去計(jì)算返回值，而當(dāng)前線程在使用這個(gè)返回值之前可以做其他操作，等到需要這個(gè)返回值時(shí)可以通過(guò)Future得到。

Future使用舉例如下：

@Slf4j
public class FutureExample {

    static class MyCallable implements Callable<String> {

        @Override
        public String call() throws Exception {
            log.info("do something in callable");
            Thread.sleep(5000);
            return "callable done";
        }
    }

    public static void main(String[] args) throws InterruptedException, ExecutionException {
        ExecutorService executorService = Executors.newCachedThreadPool();
        Future<String> future = executorService.submit(new MyCallable());
        log.info("do something in main");
        Thread.sleep(1000);
        String result = future.get(); // 如果call任務(wù)沒(méi)有結(jié)束，則會(huì)阻塞在這里
        log.info("result: {}", result);
    }
}

FutureTask舉例

@Slf4j
public class FutureTaskExample {
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        FutureTask<String> futureTask = new FutureTask<String>(new Callable<String>() {
            @Override
            public String call() throws Exception {
                log.info("do something in callable");
                Thread.sleep(5000);
                return "callable done";
            }
        });
        new Thread(futureTask).start();
        log.info("do something in main");
        Thread.sleep(1000);
        String result = futureTask.get();
        log.info("result: {}", result);
    }
}

以上就是java J.U.C中FutureTask的使用分析，小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘９ぷ鲿?huì)見(jiàn)到或用到的。希望你能通過(guò)這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注億速云行業(yè)資訊頻道。