繼續(xù)并發(fā)專題~

FutureTask 有點類似Runnable，都可以通過Thread來啟動，不過FutureTask可以返回執(zhí)行完畢的數(shù)據(jù)，并且FutureTask的get方法支持阻塞。

由于：FutureTask可以返回執(zhí)行完畢的數(shù)據(jù)，并且FutureTask的get方法支持阻塞這兩個特性，我們可以用來預先加載一些可能用到資源，然后要用的時候，調用get方法獲取（如果資源加載完，直接返回；否則繼續(xù)等待其加載完成）。

下面通過兩個例子來介紹下：

1、使用FutureTask來預加載稍后要用的的數(shù)據(jù)。

package com.zhy.concurrency.futuretask;import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask;/*** 使用FutureTask來提前加載稍后要用到的數(shù)據(jù)* * @author zhy* */ public class PreLoaderUseFutureTask {/*** 創(chuàng)建一個FutureTask用來加載資源*/private final FutureTask<String> futureTask = new FutureTask<String>(new Callable<String>(){@Overridepublic String call() throws Exception{Thread.sleep(3000);return "加載資源需要3秒";}});public final Thread thread = new Thread(futureTask);public void start(){thread.start();}/*** 獲取資源* * @return* @throws ExecutionException * @throws InterruptedException */public String getRes() throws InterruptedException, ExecutionException{return futureTask.get();//加載完畢直接返回，否則等待加載完畢}public static void main(String[] args) throws InterruptedException, ExecutionException{PreLoaderUseFutureTask task = new PreLoaderUseFutureTask();/*** 開啟預加載資源*/task.start();// 用戶在真正需要加載資源前進行了其他操作了2秒Thread.sleep(2000);/*** 獲取資源*/System.out.println(System.currentTimeMillis() + "：開始加載資源");String res = task.getRes();System.out.println(res);System.out.println(System.currentTimeMillis() + "：加載資源結束");}}
運行結果：

1400902789275：開始加載資源 加載資源需要3秒 1400902790275：加載資源結束 可以看到，本來加載資源的時間需要3秒，現(xiàn)在只花費了1秒，如果用戶其他操作時間更長，則可直接返回，極大增加了用戶體驗。

2、看下Future的API

可以看到Future的API，還是比簡單的，見名知意的感覺，get( long , TimeUnit )還能支持，設置最大等待時間，比如某個操作耗時太長，就可以取消了。

3、FutureTask模擬，用戶在線觀看電子書的預加載功能

用戶觀看當前頁時，后臺預先把下一頁加載好，這樣可以大幅度提高用戶的體驗，不需要每一頁都等待加載，用戶會覺得此電子書軟件很流暢，哈哈，用戶覺得好，才是真的好。

package com.zhy.concurrency.futuretask;import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask;/*** 使用FutureTask模擬預加載下一頁圖書的內容* * @author zhy* */ public class BookInstance {/*** 當前的頁碼*/private volatile int currentPage = 1;/*** 異步的任務獲取當前頁的內容*/FutureTask<String> futureTask = new FutureTask<String>(new Callable<String>(){@Overridepublic String call() throws Exception{return loadDataFromNet();}});/*** 實例化一本書，并傳入當前讀到的頁碼* * @param currentPage*/public BookInstance(int currentPage){this.currentPage = currentPage;/*** 直接啟動線程獲取當前頁碼內容*/Thread thread = new Thread(futureTask);thread.start();}/*** 獲取當前頁的內容* * @return* @throws InterruptedException* @throws ExecutionException*/public String getCurrentPageContent() throws InterruptedException,ExecutionException{String con = futureTask.get();this.currentPage = currentPage + 1;Thread thread = new Thread(futureTask = new FutureTask<String>(new Callable<String>(){@Overridepublic String call() throws Exception{return loadDataFromNet();}}));thread.start();return con;}/*** 根據(jù)頁碼從網(wǎng)絡抓取數(shù)據(jù)* * @return* @throws InterruptedException*/private String loadDataFromNet() throws InterruptedException{Thread.sleep(1000);return "Page " + this.currentPage + " : the content ....";}public static void main(String[] args) throws InterruptedException,ExecutionException{BookInstance instance = new BookInstance(1);for (int i = 0; i < 10; i++){long start = System.currentTimeMillis();String content = instance.getCurrentPageContent();System.out.println("[1秒閱讀時間]read:" + content);Thread.sleep(1000);System.out.println(System.currentTimeMillis() - start);}} }
輸出結果：

[1秒閱讀時間]read:Page 1 : the content .... 2001 [1秒閱讀時間]read:Page 2 : the content .... 1000 [1秒閱讀時間]read:Page 3 : the content .... 1001 [1秒閱讀時間]read:Page 4 : the content .... 1000 [1秒閱讀時間]read:Page 5 : the content .... 1001
可以看到，除了第一次觀看當前頁需要等待網(wǎng)絡加載數(shù)據(jù)的過程（輸出的：2001，1000是加載耗時，1000是用戶閱讀時間），接下來的頁面都是瞬間返回（輸出的1000是用戶閱讀時間），完全不需要等待。

代碼都是為了講解FutureTask的應用場景，，，請勿直接在項目中使用。

好了，就到這里，歡迎各位留言。

轉載于:https://www.cnblogs.com/oversea201405/p/3752002.html

總結

以上是生活随笔為你收集整理的Java 并发专题 ：FutureTask 实现预加载数据 在线看电子书、浏览器浏览网页等的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內容還不錯，歡迎將生活随笔推薦給好友。