舉例講解Java設(shè)計模式中的對象池模式編程
定義
一個對象池是一組已經(jīng)初始化過且可以使用的對象的集合,池的用戶可以從池子中取得對象,對其進行操作處理,并在不需要時歸還給池子而非銷毀它。
若初始化、實例化的代價高,且有需求需要經(jīng)常實例化,但每次實例化的數(shù)量較少的情況下,使用對象池可以獲得顯著的效能提升。從池子中取得對象的時間是可預(yù)測的,但新建一個實例所需的時間是不確定。
實現(xiàn)
1. Reusable - 對象池中的對象,通常實例化代價比較高。
2. Client - 使用一個對象的實例。
3. ReusablePool - 管理對象的實例化,回收和銷毀。
單個實例中主要的思想
1.一個棧,這里用stack
2.初始化方法,容器開啟的時候可以預(yù)先創(chuàng)建池
3.創(chuàng)建實例的方法
4.提供從池中獲得對象實例的方法
5.提供返回的方法,不返回后果很嚴重
6.控制請求等待時間的方法,過了一定的事件還沒獲得對象實例,就返回一個null指針
import java.util.Stack; @SuppressWarnings("unchecked") public class ObjectPool { public ObjectPool() { } private PoolParam poolParam; public void setPoolParam(PoolParam poolParam) { this.poolParam = poolParam; } // 當(dāng)前總對象個數(shù) private int currentNum = 0; private Class clazz; public void setClazz(Class clazz) { this.clazz = clazz; } // 棧,用來存放對象,模擬一個池 private Stack stack; public Stack getStack() { return stack; } public void setStack(Stack stack) { this.stack = stack; } // ................................................................. // 等待超時的記數(shù)變量 private int timeWait = 0; // ................................................................. // 創(chuàng)建對象池 public void initalPool(PoolParam poolParam, Class clazz) { this.setPoolParam(poolParam); this.setClazz(clazz); stack = new Stack(); stack.clear(); // System.out.println("obj..pool is initial..."); // 生成配置最小對象數(shù),并壓入棧中 try { for (int i = 0; i < poolParam.getMinObjectCount(); i++) { // 根據(jù)poolParam初始化對象池 stack.push(clazz.newInstance()); } } catch (InstantiationException e) { e.printStackTrace(); } catch (IllegalAccessException e) { e.printStackTrace(); } } // 創(chuàng)建單個對象 private Object createObj(Class clazz) { Object obj = null; try { obj = clazz.newInstance(); // System.out.println("a new one..."); } catch (InstantiationException e) { e.printStackTrace(); } catch (IllegalAccessException e) { e.printStackTrace(); } return obj; } // 對象池提供的get方法 public Object getInstance(){ // System.out.println(stack.size()); Object object = null; if (stack.size() == 0) { // 如果當(dāng)前棧的長度為0,并且總的對象數(shù)沒有超過定義最大數(shù) if ((currentNum + poolParam.getMinObjectCount()) < poolParam .getMaxObjectCount()) { // 新創(chuàng)建一個對象 object = this.createObj(clazz); // 對象數(shù)+1 currentNum++; } else { synchronized (this) { try { waitme(this); } catch (Exception e) { e.printStackTrace(); } // 獲得通知后檢測棧中是為空,并給出剛剛釋放的資源 if (!stack.empty()) { object = stack.pop(); } } } } else if (stack.size() > 0) { object = stack.pop(); // System.out.println(stack.size()); } return object; } // 返回對象的方法 public void returnObj(Object obj) { if (clazz.isInstance(obj)) { stack.push(obj); synchronized (this) { notify(); } } else { System.out.println("this object can not push to stack!"); } } // 等待遞歸算法 private void waitme(ObjectPool pool) { // 等待2s的技術(shù)控制 if (timeWait >= 2000) { System.out.println("jump up this step.."); timeWait = 0; return; } else { try { pool.wait(500); // 等待計數(shù)累加。。 timeWait +=1000; System.out.println("waiting time to free obj.."); if (stack.empty()) { System.out.println("agian...."); waitme(pool); } } catch (InterruptedException e) { e.printStackTrace(); } } } }
管理池類,這個不是很難,同步了就好
@SuppressWarnings("unchecked") public class ObjectPoolManage { private ObjectPoolManage() { } private static ObjectPool pool; // 實現(xiàn)一個單例的獲取方法....默認 public static synchronized ObjectPool getCacheObject(Class clazz) { if (null != pool) { return pool; } else { createObjectPool(null, clazz); return pool; } } // 實現(xiàn)一個單例的獲取方法...自定義 public static synchronized ObjectPool getCacheObject(PoolParam p, Class clazz) { if (null != pool) { return pool; } else { createObjectPool(p, clazz); return pool; } } private static ObjectPool createObjectPool(PoolParam p, Class clazz) { pool = new ObjectPool(); if (null == p) { pool.initalPool(new PoolParam(5,10), clazz); } else { pool.initalPool(p, clazz); } return pool; } private static Class getclazz(){ Class clazz=null; try { clazz= Class.forName(ppp.getPropertyByName("objectPath")); } catch (ClassNotFoundException e) { e.printStackTrace(); } return clazz; } }
相關(guān)問題和實現(xiàn)
1. 對象池中可以限制對象的個數(shù),當(dāng)超過限制時,對象池需要返回異?;蛘呖罩担酝ㄖ蛻?。
2. 在多線程環(huán)境中,在checkout和checkin方法需要同步。
3. 定時清理過期的對象。
相關(guān)文章
Java String轉(zhuǎn)換時為null的解決方法
這篇文章主要介紹了Java String轉(zhuǎn)換時為null的解決方法,需要的朋友可以參考下2017-07-07SpringBoot項目打成War布署在Tomcat的詳細步驟
這篇文章主要介紹了SpringBoot項目打成War布署在Tomcat,本文分步驟結(jié)合圖文實例給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2022-03-03idea全局設(shè)置Maven配置的實現(xiàn)步驟
本文主要介紹了idea全局設(shè)置Maven配置,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-07-07