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

本篇文章給大家分享的是有關java J.U.C中FutureTask的使用分析，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

FutureTask是J.U.C里面的，但是它不是AQS的子類，但是這個類對線程結果的處理很值得我們學習和在項目中使用。

創建一個線程通常有兩種方式，一種是直接繼承Thread、另一種是直接實現Runnable，這兩種方式有一個共同的缺陷就是在執行完任務之后無法獲取執行結果。從java1.5開始就提供了Callable和Future，通過他們可以在任務完成之后得到任務的執行結果。

Callable與Runnable對比

• Runnable接口代碼簡單，只有一個方法run()

• Callable是一個泛型接口，有一個call函數，call的返回類型就是創建Callable的類型，功能更強大一些。

Future接口

對于一個具體的Callable和Runnable任務，Future可以進行取消、查詢一個任務是否被取消、查詢是否完成、獲取結果等等。通常線程都是異步執行的，因此不可能從其他線程中得到返回值。Future可以監視目標線程call的情況，當調用Future的get()時就可以獲得它的結果，這時線程可能不會直接完成，當前線程開始阻塞，直到call方法結束并返回結果，線程才繼續執行。總結一句話，Future可以得到其他線程任務方法的結果返回值。

FutureTask類

FutureTask類的父類是RunnableFuture，而RunnableFuture繼承了Runnable和Future兩個接口。由此可以知道FutureTask最終也是執行Callable類型的任務。如果構造函數參數是Runnable的話，會自動轉換成Callable類型。FutureTask實現了兩個接口（Runnable和Future），所以它既可以作為Runnable被線程執行，又可以作為Future得到Callable的返回值。RunnableFuture繼承了Runnable接口和Future接口，而FutureTask實現了RunnableFuture接口。

那么，這個組合的使用有什么好處呢？假設有一個很費時的邏輯，需要計算并返回計算結果，同時這個值不是馬上需要，那么就可以使用這個組合，用另外一個線程去計算返回值，而當前線程在使用這個返回值之前可以做其他操作，等到需要這個返回值時可以通過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任務沒有結束，則會阻塞在這里
        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的使用分析，小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。