简单缓存
package com.william.job;
import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
public class CacheMgr {
?private static Map cacheMap = new HashMap();
?private static Map cacheConfMap = new HashMap();
?private CacheMgr() {
?}
?private static CacheMgr cm = null;
?public static CacheMgr getInstance() {
??if (cm == null) {
???cm = new CacheMgr();
???Thread t = new ClearCache();
???t.start();
??}
??return cm;
?}
?/**
? * 增加缓存
? *
? * @param key
? * @param value
? * @param ccm
? *??????????? 缓存对象
? * @return
? */
?public boolean addCache(Object key, Object value, CacheConfModel ccm) {
??boolean flag = false;
??cacheMap.put(key, value);
??cacheConfMap.put(key, ccm);
??System.out.println("now addcache==" + cacheMap.size());
??return true;
?}
?/**
? * 重载了增加缓存方法，
? * @param key
? * @param value
? * @param beginTime
? * @param durableTime -----分钟
? * @param isForever
? * @return
? */
?public boolean addCache(Object key, Object value, long beginTime,int durableTime,boolean isForever) {
??cacheMap.put(key, value);
??CacheConfModel ccm = new CacheConfModel();
??ccm.setBeginTime(beginTime);
??ccm.setDurableTime(durableTime);
??ccm.setForever(isForever);
??cacheConfMap.put(key, ccm);
??System.out.println("now addcache==" + cacheMap.size());
??return true;
?}
?/**
? * 删除缓存
? *
? * @param key
? * @return
? */
?public boolean removeCache(Object key) {
??cacheMap.remove(key);
??cacheConfMap.remove(key);
??System.out.println("now removeCache==" + cacheMap.size());
??return true;
?}
?/**
? * 获取缓存
? * @param key
? * @return
? */
?public Object getData(Object key)
?{
??return cacheMap.get(key);
?}
?
?
?/**
? * 清除缓存的类
? *
? * @author wanglj 继承Thread线程类
? */
?private static class ClearCache extends Thread {
??public void run() {
???while (true) {
????Set tempSet = new HashSet();
????Set set = cacheConfMap.keySet();
????Iterator it = set.iterator();
????while (it.hasNext()) {
?????Object key = it.next();
?????CacheConfModel ccm = (CacheConfModel) cacheConfMap.get(key);
?????// 比较是否需要清除
?????if (!ccm.isForever()) {
??????if ((new Date().getTime() - ccm.getBeginTime()) >= ccm
????????.getDurableTime() * 60 * 1000) {
???????// 可以清除，先记录下来
???????tempSet.add(key);
??????}
?????}
????}
????// 真正清除
????Iterator tempIt = tempSet.iterator();
????while (tempIt.hasNext()) {
?????Object key = tempIt.next();
?????cacheMap.remove(key);
?????cacheConfMap.remove(key);
????}
????System.out.println("now thread================>"
??????+ cacheMap.size());
????// 休息
????try {
?????Thread.sleep(60 * 1000L);
????} catch (InterruptedException e) {
?????// TODO Auto-generated catch block
?????e.printStackTrace();
????}
???}
??}
?}
}
?
?
?
package com.william.job;
public class CacheConfModel implements java.io.Serializable {
?private long beginTime;
?private boolean isForever = false;
?private int durableTime;
?public long getBeginTime() {
??return beginTime;
?}
?public void setBeginTime(long beginTime) {
??this.beginTime = beginTime;
?}
?public boolean isForever() {
??return isForever;
?}
?public void setForever(boolean isForever) {
??this.isForever = isForever;
?}
?public int getDurableTime() {
??return durableTime;
?}
?public void setDurableTime(int durableTime) {
??this.durableTime = durableTime;
?}
}
