当前页面: 开发资料首页 → Java 专题 → 对象池(对象缓冲池)－－－采用最近最久未使用策略管理对象,同时带有事件监听功能
对象池(对象缓冲池)－－－采用最近最久未使用策略管理对象,同时带有事件监听功能
摘要: 对象池(对象缓冲池)－－－采用最近最久未使用策略管理对象,同时带有事件监听功能
package memorymanager.lrucache;
import java.util.*;
/**
*
Title: 对象缓冲池－－－采用最近最久未使用策略管理对象,同时带有事件监听功能
*
工作原理
*
*
*
*
*
*
*
*
*
其他说明
* 这个类参考了org.apache.tomcat.util.collections.LRUCache的实现细节。
* 当然原代码采用Hashtable来存储池的对象列表，这里采用另外的存储方式－－－HashMap来存储
*
*
Copyright: Copyright (c) 2004
*
Company:
*@see org.apache.tomcat.util.collections.LRUCache
*
* @author wdz123@hotmail.com
* @version 1.0
*/
public class LRUCacheWithListener {
/**
* 池对象的包裹类，这样便于相关处理
* **/
class CacheNode {
CacheNode prev;
CacheNode next;
Abandon value;
Object key;
public CacheNode() {
}
}
/**
* 对象池大小
**/
private int cacheSize;
/**
* 对象列表、当然可以采用泛型编程，这样就实现自动装箱、解箱(boxing/unboxing)
* **/
private HashMap nodes;
/**
* 对象池当前对象数
* **/
private int currentSize;
/**
* 第一个节点
* **/
private CacheNode first;
/***
* 最后一个节点
* **/
private CacheNode last;
/**
* 对象锁
* 实际上下面也就几个地方使用了该锁，可以用同步方法来取代调使用这个对象锁
* **/
private static int DEFAULT_SIZE = 10;
public LRUCacheWithListener() {
this(DEFAULT_SIZE);
}
public LRUCacheWithListener(int poolSize) {
cacheSize = poolSize;
currentSize = 0;
first = null; //
last = null; //
nodes = new HashMap(poolSize);
}
/**
* 读取一个对象
* ***/
public synchronized Object get(Object key) {
CacheNode node = (CacheNode) nodes.get(key);
if (node != null) {
moveToHead(node);
return node.value;
}
else {
return null;
}
}
/**
* 把指定对象移动到链表的头部
* */
private void moveToHead(CacheNode node) {
if (node == first) {
return;
}
if (node.prev != null) {
node.prev.next = node.next;
}
if (node.next != null) {
node.next.prev = node.prev;
}
if (last == node) {
last = node.prev;
}
if (first != null) {
node.next = first;
first.prev = node;
}
first = node;
node.prev = null;
if (last == null) {
last = first;
}
}
/**
* 删除池中指定对象
* **/
public synchronized Object remove(Object key) {
CacheNode node = (CacheNode) nodes.get(key);
if (node != null) {
if (node.prev != null) {
node.prev.next = node.next;
}
if (node.next != null) {
node.next.prev = node.prev;
}
if (last == node) {
last = node.prev;
}
if (first == node) {
first = node.next;
}
}
return node;
}
/****
* 放置一个对象到池中
* */
public synchronized void put(Object key, Abandon value) {
CacheNode node = (CacheNode) nodes.get(key);
if (node == null) {
//池满，删除最久没有使用的对象
if (currentSize >= cacheSize) {
if (last != null) {
nodes.remove(last.key);
}
removeLast();
}
//池没有满，直接把对象放入池中
else {
currentSize++;
}
node = getANewCacheNode();
}
node.value = value;
node.key = key;
// 把放入池的这个对象移动到链表的头部，表示最近最短被使用过
moveToHead(node);
nodes.put(key, node);
}
/**晴空池中对象
* **/
public synchronized void clear() {
if (first!=null){
Iterator i= nodes.values().iterator();
//触发事件，该池已经被清空
CacheNode n;
while(i.hasNext()){
n = (CacheNode)(i.next());
n.value.poolClear();
}
}
first = null;
last = null;
}
/***
* 获得一个新的包裹对象
* **/
private CacheNode getANewCacheNode(){
CacheNode node = new CacheNode();
return node;
}
/**
* 删除池中最久没有使用的对象
* **/
private void removeLast() {
if (last != null) {
//对象从池中被抛弃，触发事件
last.value.onAbandon();
if (last.prev != null) {
last.prev.next = null;
}
else {
first = null;
}
last = last.prev;
}
}
}
******代码2
package memorymanager.lrucache;
/**
*
Title:
*
*
Description: 定义对象被抛弃和池被清空的事件接口
*
*
Copyright: Copyright (c) 2003
*
*@see org.apache.tomcat.util.collections.LRUCache
*
* @author wdz123@hotmail.com
* @version 1.0
*/
public interface Abandon {
//
public void onAbandon();
public void poolClear();
}
代码3，测试部分
package memorymanager.lrucache;
/**
*
Title:
*
*
Description: 测试使用带有事件回调机制的对象缓冲池－－－采用最近最久未使用策略管理对象
*
*
Copyright: Copyright (c) 2003
*
*@see org.apache.tomcat.util.collections.LRUCache
*
* @author wdz123@hotmail.com
* @version 1.0
*/
public class CacheNodeWithListener implements Abandon {
int id;
public CacheNodeWithListener() {
}
public CacheNodeWithListener(int i) {
id=i;
}
/**
* 当对象被池所抛弃时候，进行相关处理
* ***/
public void onAbandon(){
System.out.println(this+"---onAbandon()");
}
/**
* 当对象池被清空时候，进行相关处理
* ***/
public void poolClear(){
System.out.println(this+"---poolClear()");
}
public String toString(){
return "id="+id ;
}
static public void main(String [] s){
LRUCacheWithListener pool =new LRUCacheWithListener(3);
int i;
for (i=1;i<=5;i++) {
pool.put("obj"+i,new CacheNodeWithListener(i));
}
pool.clear();
}
}
Java, java, J2SE, j2se, J2EE, j2ee, J2ME, j2me, ejb, ejb3, JBOSS, jboss, spring, hibernate, jdo, struts, webwork, ajax, AJAX, mysql, MySQL, Oracle, Weblogic, Websphere, scjp, scjd //*************************************代码1****************************************
package memorymanager.lrucache;
import java.util.*;
/**
*
Title: 对象缓冲池－－－采用最近最久未使用策略管理对象,同时带有事件
↑返回目录
前一篇: 经典java问题,你能答出几个?
后一篇: 多人在线游戏开发心得(服务器端)