• Future模式，也是非常經典的設計模式，這種模式主要就利用空間換時間的概念，也就是說異步執行（需要開啟一個新的線程）
• 在互聯網高并發的應用服務中，我們隨處可見這種理念和代碼，主要就是使用了這種模式
• ?Future模式非常適合在處理耗時很長的業務邏輯時進行使用，可以有效的減小系統的響應時間，提高系統的吞吐量

package com.example.core.juc;import java.util.concurrent.*;public class UseFuture implements Callable<String> {private String param;public UseFuture(String param){this.param = param;}@Overridepublic String call() throws Exception{//模擬執行業務的耗時Thread.sleep(3000);String result = this.param =",處理完成";return result;}public static void main(String[] args) throws InterruptedException, ExecutionException {String queryStr1 = "query1";String queryStr2 = "query2";FutureTask<String> future1 = new FutureTask<String>(new UseFuture(queryStr1));FutureTask<String> future2 = new FutureTask<String>(new UseFuture(queryStr2));ExecutorService executorService = Executors.newFixedThreadPool(2);executorService.submit(future1);//異步的操作executorService.submit(future2);//異步的操作System.out.println("處理其他的任務");Thread.sleep(2000);String ret1 = future1.get();String ret2 = future2.get();System.out.println("數據處理完成"+ret1);System.out.println("數據處理完成"+ret2); /* output: 處理其他的任務 數據處理完成,處理完成 數據處理完成,處理完成*/} }

future設計模式

• 最為關鍵的就是FutureData包裝類，當客戶端發出請求，FutureData會接收并返回請求，但是此時這個call return并不包含真是的數據，FutureData會發送other call去獲取真實的數據類，再將真實的數據類返回，用于真正的實際使用。

• Future模式有點類似于商品訂單。 比如在網購時，當看重某一件商品事，就可以提交訂單，當訂單處理完成后，在家里等待商品送貨上門即可
• ?或者說更形象的我們發送Ajax請求的時候，頁面是異步的進行后臺處理，用戶無須一直等待請求的結果，可以繼續瀏覽或操作其他內容

例子

• 網購時，當看重某一件商品事，就可以提交訂單，當訂單處理完成后，在家里等待商品送貨上門即可
• 當客戶端發起請求，返回包裝類對象，另外起一個線程去查詢數據，再將真實的數據返回

• Main.java

package com.example.core.future;public class Main {public static void main(String[] args) {FutureClient fc = new FutureClient();Data data = fc.request("請求參數");//異步執行System.out.println("做其他的相關業務操作");String rst = data.getRequest();//這才是真正的獲取實際數據的方法System.out.println("---"+rst);} } /* 做其他的相關業務操作 根據查詢參數：請求參數進行查詢數據庫操作這可能需要5秒左右的時間 ---100條數據*/

• Data抽象層?

package com.example.core.future;public interface Data {String getRequest(); }

• FutureClient.java

package com.example.core.future;public class FutureClient {public Data request(final String queryStr){FutureData futureData = new FutureData();//異步的起一個線程去進行相應的處理操作new Thread(new Runnable() {@Overridepublic void run() {//需要把請求的參數 設置到真實數據的處理對象中去RealData realData = new RealData(queryStr);//真實請求處理完成之后，我們需要進行設置，將結果給包裝對象futureData.setRealData(realData);}}).start();;return futureData;} }

• FutureData.java

package com.example.core.future;public class FutureData implements Data{//真實數據對象的引用private RealData realData;//實際處理的狀態private boolean isReady = false;public synchronized void setRealData(RealData realData){if (isReady){return ;}//如果是真實的對象賦值成功，那么就認為數據已經準備好了this.realData = realData;isReady = true;//真實的數據已經準備好了，我們進行喚醒操作notify();}@Overridepublic synchronized String getRequest() {while(!isReady){try{wait();}catch (InterruptedException e){e.printStackTrace();}}return this.realData.getRequest();} }

• RealData.java

package com.example.core.future;public class RealData implements Data{private String result;public RealData(String queryStr){System.out.println("根據查詢參數："+queryStr+"進行查詢數據庫操作這可能需要5秒左右的時間");try{//時間的查詢耗時Thread.sleep(5000);}catch (InterruptedException e){e.printStackTrace();}result = "100條數據";}@Overridepublic String getRequest() {return result;} }

?

?

總結

以上是生活随笔為你收集整理的Java JUC工具类--Future的全部內容，希望文章能夠幫你解決所遇到的問題。

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