当前位置: 开发笔记 > 运维 > 正文

Java中LocalCache本地缓存实现代码

作者：蘑菇宝 | 来源：互联网 | 2021-11-01 02:24

前言本次分享探讨java平台的本地缓存，是指占用JVM的heap区域来缓冲存储数据的缓存组件。一、本地缓存应用场景 l

前言

本次分享探讨java平台的本地缓存，是指占用JVM的heap区域来缓冲存储数据的缓存组件。

一、本地缓存应用场景

localcache有着极大的性能优势：

1. 单机情况下适当使用localcache会使应用的性能得到很大的提升。

2. 集群环境下对于敏感性要求不高的数据可以使用localcache，只配置简单的失效机制来保证数据的相对一致性。

哪些数据可以存储到本地缓存？

1．访问频繁的数据；

2．静态基础数据（长时间内不变的数据）；

3．相对静态数据（短时间内不变的数据）。

二、java本地缓存标准

Java缓存新标准（javax.cache），这个标准由JSR107所提出，已经被包含在Java EE 7中。

特性：
1．原子操作，跟java.util.ConcurrentMap类似
2．从缓存中读取
3．写入缓存
4．缓存事件监听器
5．数据统计
6．包含所有隔离（ioslation）级别的事务
7．缓存注解（annotations）
8．保存定义key和值类型的泛型缓存
9．引用保存（只适用于堆缓存）和值保存定义

但目前应用不是很普遍。

三、java开源缓存框架

比较有名的本地缓存开源框架有：

1．EHCache

EHCache是一个纯java的在进程中的缓存，它具有以下特性：快速，简单，为Hibernate2.1充当可插入的缓存，最小的依赖性，全面的文档和测试。

BUG：过期失效的缓存元素无法被GC掉，时间越长缓存越多，内存占用越大，导致内存泄漏的概率越大。

2．OSCache

OSCache有以下特点：缓存任何对象，你可以不受限制的缓存部分jsp页面或HTTP请求，任何java对象都可以缓存。拥有全面的API--OSCache API给你全面的程序来控制所有的OSCache特性。永久缓存--缓存能随意的写入硬盘，因此允许昂贵的创建(expensive-to-create)数据来保持缓存，甚至能让应用重启。支持集群--集群缓存数据能被单个的进行参数配置，不需要修改代码。缓存记录的过期--你可以有最大限度的控制缓存对象的过期，包括可插入式的刷新策略(如果默认性能不需要时)。

3．JCache

Java缓存新标准（javax.cache）

4．cache4j

cache4j是一个有简单API与实现快速的Java对象缓存。它的特性包括：在内存中进行缓存，设计用于多线程环境，两种实现：同步与阻塞，多种缓存清除策略：LFU, LRU, FIFO，可使用强引用。

5．ShiftOne

ShiftOne Java Object Cache是一个执行一系列严格的对象缓存策略的Java lib，就像一个轻量级的配置缓存工作状态的框架。

6．WhirlyCache

Whirlycache是一个快速的、可配置的、存在于内存中的对象的缓存。

四、LocalCache实现

1、LocalCache简介

LocalCache是一个精简版本地缓存组件，有以下特点：

1．有容量上限maxCapacity；
2．缓存达到容量上限时基于LRU策略来移除缓存元素；
3．缓存对象的生命周期（缓存失效时间）由调用方决定；
4．缓存对象失效后，将会有定时清理线程来清理掉，不会导致内存泄漏。
5．性能比Ehcache稍强。

2、总体设计

LocalCache总体设计：

1．缓存元素 CacheElement；
2．缓存容器 LRULinkedHashMap；
3．缓存接口 Cache；
4．缓存组件实现 LocalCache。

3、详细设计

1． CacheElement设计

/**
 * 缓存元素
 *
 */
public class CacheElement {
 private Object key;
 private Object value;
 private long createTime;
 private long lifeTime;
 private int hitCount;

 public CacheElement() {
 }

 public CacheElement(Object key ,Object value) {
 this.key = key;
 this.value = value;
 this.createTime = System.currentTimeMillis();
 }
 
 public Object getKey() {
 return key;
 }

 public void setKey(Object key) {
 this.key = key;
 }

 public Object getValue() {
 hitCount++;
 return value;
 }

 public void setValue(Object value) {
 this.value = value;
 }

 public long getCreateTime() {
 return createTime;
 }

 public void setCreateTime(long createTime) {
 this.createTime = createTime;
 }

 public int getHitCount() {
 return hitCount;
 }

 public void setHitCount(int hitCount) {
 this.hitCount = hitCount;
 }

 public long getLifeTime() {
 return lifeTime;
 }

 public void setLifeTime(long lifeTime) {
 this.lifeTime = lifeTime;
 }
 
 public boolean isExpired() {
 boolean isExpired = System.currentTimeMillis() - getCreateTime() > getLifeTime();
 return isExpired;
 }

 /*
 * (non-Javadoc)
 * @see java.lang.Object#toString()
 */
 public String toString() {
 StringBuffer sb = new StringBuffer();
 sb.append("[ key=").append(key).append(", isExpired=").append(isExpired())
  .append(", lifeTime=").append(lifeTime).append(", createTime=").append(createTime)
  .append(", hitCount=").append(hitCount)
  .append(", value=").append(value).append(" ]");
 return sb.toString();
 }
 
 /*
 * (non-Javadoc)
 * @see java.lang.Object#hashCode()
 */
 public final int hashCode(){
 if(null == key){
  return "".hashCode();
 }
 return this.key.hashCode();
 }
 
 /*
 * (non-Javadoc)
 * @see java.lang.Object#equals(java.lang.Object)
 */
 public final boolean equals(Object object) {
 if ((object == null) || (!(object instanceof CacheElement))) {
  return false;
 }

 CacheElement element = (CacheElement) object;
 if ((this.key == null) || (element.getKey() == null)) {
  return false;
 }

 return this.key.equals(element.getKey());
 }
}

2． LRULinkedHashMap实现

import java.util.LinkedHashMap;
import java.util.Set;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
 * 实现 LRU策略的 LinkedHashMap
 *
 * @param 
 * @param 
 */
public class LRULinkedHashMap extends LinkedHashMap 
{ 
 protected static final long serialVersiOnUID= 2828675280716975892L;
 
 protected static final int DEFAULT_MAX_ENTRIES = 100;
 
 protected final int initialCapacity; 
 protected final int maxCapacity; 
 protected boolean enableRemoveEldestEntry = true;//是否允许自动移除比较旧的元素(添加元素时)
 
 protected static final float DEFAULT_LOAD_FACTOR = 0.8f; 
 protected final Lock lock = new ReentrantLock(); 

  public LRULinkedHashMap(int initialCapacity) 
  { 
   this(initialCapacity, DEFAULT_MAX_ENTRIES);
  }
  
  public LRULinkedHashMap(int initialCapacity ,int maxCapacity) 
  { 
   //set accessOrder=true, LRU
    super(initialCapacity, DEFAULT_LOAD_FACTOR, true); 
    
    this.initialCapacity = initialCapacity; 
    this.maxCapacity = maxCapacity; 
  }

  /*
   *  (non-Javadoc)
   * @see java.util.LinkedHashMap#removeEldestEntry(java.util.Map.Entry)
   */
  protected boolean removeEldestEntry(java.util.Map.Entry eldest) 
  { 
    return enableRemoveEldestEntry && ( size() > maxCapacity );
  } 

 /*
 *  (non-Javadoc)
 * @see java.util.LinkedHashMap#get(java.lang.Object)
 */
  public V get(Object key) 
  { 
    try { 
      lock.lock(); 
      return super.get(key); 
    } 
    finally { 
      lock.unlock(); 
    } 
  } 

  /*
   *  (non-Javadoc)
   * @see java.util.HashMap#put(java.lang.Object, java.lang.Object)
   */
  public V put(K key, V value) 
  { 
    try { 
      lock.lock(); 
      return super.put(key, value); 
    } 
    finally { 
      lock.unlock(); 
    } 
  } 
  
  /*
   * (non-Javadoc)
   * @see java.util.HashMap#remove(java.lang.Object)
   */
  public V remove(Object key) {
    try { 
      lock.lock();
      return super.remove(key);
    } 
    finally { 
      lock.unlock(); 
    }
  }
  
  /*
   * (non-Javadoc)
   * @see java.util.LinkedHashMap#clear()
   */
  public void clear() {
   try { 
       lock.lock();
       super.clear();
     } 
     finally { 
       lock.unlock();
     }
  }
  
  /*
   * (non-Javadoc)
   * @see java.util.HashMap#keySet()
   */
  public Set keySet() {
   try { 
      lock.lock();
      return super.keySet();
    } 
    finally { 
      lock.unlock();
    }
  }
  
  public boolean isEnableRemoveEldestEntry() {
 return enableRemoveEldestEntry;
 }
 public void setEnableRemoveEldestEntry(boolean enableRemoveEldestEntry) {
 this.enableRemoveEldestEntry = enableRemoveEldestEntry;
 }
 public int getInitialCapacity() {
 return initialCapacity;
 }
 public int getMaxCapacity() {
 return maxCapacity;
 }
}

3． Cache接口设计

/**
 * 缓存接口
 *
 */
public interface Cache {
 
 /**
 * 获取缓存
 * @param key
 * @return
 */
 public  T getCache(Object key);
 
 /**
 * 缓存对象
 * @param key
 * @param value
 * @param milliSecond 缓存生命周期(毫秒)
 */
 public void putCache(Object key, Object value ,Long milliSecond);
 
 /**
 * 缓存容器中是否包含 key 
 * @param key
 * @return
 */
 public boolean containsKey(Object key);
 
 /**
 * 缓存列表大小
 * @return
 */
 public int getSize();
 
 /**
 * 是否启用缓存
 */
 public boolean isEnabled();
 /**
 * 启用 或 停止
 * @param enable
 */
 public void setEnabled(boolean enabled);
 
 /**
 * 移除所有缓存
 */
 public void invalidateCaches();
 
 /**
 * 移除 指定key缓存
 * @param key
 */
 public void invalidateCache(Object key);
}

4． LocalCache实现

import java.util.Date;
import java.util.Iterator;
import java.util.Random;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 本地缓存组件
 */
public class LocalCache implements Cache{
 private Logger logger = LoggerFactory.getLogger(this.getClass());
 
 private LRULinkedHashMap cacheMap;
 
 protected boolean initFlag = false;//初始化标识
 
 protected final long defaultLifeTime = 5 * 60 * 1000;//5分钟
 protected boolean warnLOngerLifeTime= false;
 
 protected final int DEFAULT_INITIAL_CAPACITY = 100;
 protected final int DEFAULT_MAX_CAPACITY = 100000;
 
 protected int initialCapacity = DEFAULT_INITIAL_CAPACITY;//初始化缓存容量
 protected int maxCapacity = DEFAULT_MAX_CAPACITY;//最大缓存容量
 protected int timeout = 20;//存取缓存操作响应超时时间(毫秒数)
 
 private boolean enabled = true;
 
 private Thread gcThread = null;
 private String lastGCInfo = null;//最后一次GC清理信息{ size, removeCount, time ,nowTime}
 private boolean logGCDetail = false;//记录gc清理细节
 
 private boolean enableGC = true;//是否允许清理的缓存(添加元素时)
 private int gcMode = 0;//清理过期元素模式 { 0=迭代模式 ; 1=随机模式 }
 private int gcIntervalTime = 2 * 60 * 1000;//间隔时间(分钟)
 
 private boolean iterateScanAll = true;//是否迭代扫描全部
 private float gcFactor = 0.5F;//清理百分比
 private int maxIterateSize = DEFAULT_MAX_CAPACITY/2;//迭代模式下一次最大迭代数量
 private volatile int iterateLastIndex = 0;//最后迭代下标
 private int maxRandomTimes = 100;//随机模式下最大随机次数
 
 
 protected final static Random random = new Random();
 private static LocalCache instance = new LocalCache();
 public static LocalCache getInstance() {
 return instance;
 }
 private LocalCache(){
 this.init();
 }
 
 protected synchronized void init() {
 if(initFlag){
  logger.warn("init repeat.");
  return ;
 }
 
 this.initCache();
 
 this.startGCDaemonThread();
 
 initFlag = true;
 
 if(logger.isInfoEnabled()){
  logger.info("init -- OK");
 }
 }
 
 private void startGCDaemonThread(){
 if(initFlag){
  return ;
 }
 
 this.maxIterateSize = maxCapacity /2;
 try{
  this.gcThread = new Thread() {
  public void run() {
   logger.info("[" + (Thread.currentThread().getName()) + "]start...");
   //sleep
   try {
   Thread.sleep(getGcIntervalTime() <30000 &＃63; 30000 : getGcIntervalTime());
   } catch (Exception e) {
   e.printStackTrace();
   }
   while( true ){
   //gc
   gc();
   //sleep
   try {
    Thread.sleep(getGcIntervalTime() <30000 &＃63; 30000 : getGcIntervalTime());
   } catch (Exception e) {
    e.printStackTrace();
   }
   }
  }
  };
  this.gcThread.setName("localCache-gcThread");
  this.gcThread.setDaemon(true);
  this.gcThread.start();
  
  if(logger.isInfoEnabled()){
  logger.info("startGCDaemonThread -- OK");
  }
 }catch(Exception e){
  logger.error("[localCache gc]DaemonThread -- error: " + e.getMessage(), e);
 }
 }
 
 private void initCache(){
 if(initFlag){
  return ;
 }
 
 initialCapacity = (initialCapacity <= 0 &＃63; DEFAULT_INITIAL_CAPACITY : initialCapacity);
 maxCapacity = (maxCapacity  T getCache(Object key) {
 if(!isEnabled()){
  return null;
 }
 long st = System.currentTimeMillis();
 
 T objValue = null;
 CacheElement cacheObj = cacheMap.get(key);
 
 if (isExpiredCache(cacheObj)) {
  cacheMap.remove(key);
 }else {
  objValue = (T) (cacheObj == null &＃63; null : cacheObj.getValue());
 }
 
 long et = System.currentTimeMillis();
 if((et - st)>timeout){
  if(this.logger.isWarnEnabled()){
  this.logger.warn("getCache_timeout_" + (et - st) + "_[" + key + "]");
  }
 }
 
 if(logger.isDebugEnabled()){
  String message = ("get( " + key + ") return: " + objValue);
  logger.debug(message);
 }
 return objValue;
 }

 /*
 * (non-Javadoc)
 */
 public void putCache(Object key, Object value ,Long lifeTime) {
 if(!isEnabled()){
  return;
 }
 Long st = System.currentTimeMillis();
 
 lifeTime = (null == lifeTime &＃63; defaultLifeTime : lifeTime);
 CacheElement cacheObj = new CacheElement();
 cacheObj.setCreateTime(System.currentTimeMillis());
 cacheObj.setLifeTime(lifeTime);
 cacheObj.setValue(value);
 cacheObj.setKey(key);
 cacheMap.put(key, cacheObj);
 
 long et = System.currentTimeMillis();
 if((et - st)>timeout){
  if(this.logger.isWarnEnabled()){
  this.logger.warn("putCache_timeout_" + (et - st) + "_[" + key + "]");
  }
 }
 
 if(logger.isDebugEnabled()){
  String message = ("putCache( " + cacheObj + " ) , 耗时 " + (et - st) + "(毫秒).");
  logger.debug(message);
 }
 if(lifeTime > defaultLifeTime && this.isWarnLongerLifeTime()){
  if(logger.isWarnEnabled()){
  String message = ("LifeTime[" + (lifeTime/1000) + "秒] too long for putCache(" + cacheObj + ")");
  logger.warn(message);
  }
 }
 }
 
 /**
 * key 是否过期
 * @param key
 * @return
 */
 protected boolean isExpiredKey(Object key) {
 CacheElement cacheObj = cacheMap.get(key);
 return this.isExpiredCache(cacheObj);
 }
 
 /**
 * cacheObj 是否过期
 * @param key
 * @return
 */
 protected boolean isExpiredCache(CacheElement cacheObj) {
 if (cacheObj == null) {
  return false;
 }
 return cacheObj.isExpired();
 }
 
 /*
 * (non-Javadoc)
 */
 public void invalidateCaches(){
 try{
  cacheMap.clear();
 }catch(Exception e){
  e.printStackTrace();
 }
 }
 
 /*
 * (non-Javadoc)
 */
 public void invalidateCache(Object key){
 try{
  cacheMap.remove(key);
 }catch(Exception e){
  e.printStackTrace();
 }
 }
 
 /*
 * (non-Javadoc)
 */
 public boolean containsKey(Object key) {
 return cacheMap.containsKey(key);
 }

 /*
 * (non-Javadoc)
 */
 public int getSize() {
 return cacheMap.size();
 }

 /*
 * (non-Javadoc)
 */
 public Iterator getKeyIterator() {
 return cacheMap.keySet().iterator();
 }

 /*
 * (non-Javadoc)
 */
 public boolean isEnabled() {
 return this.enabled;
 }

 /*
 * (non-Javadoc)
 */
 public void setEnabled(boolean enabled) {
 this.enabled = enabled;
 if(!this.enabled){
  //清理缓存
  this.invalidateCaches();
 }
 }
 
  /**
   * 清理过期缓存
   */
  protected synchronized boolean gc(){
   
   if(!isEnableGC()){
   return false;
   }
   
   try{
   
   iterateRemoveExpiredCache();
   
 }catch(Exception e){
  logger.error("gc() has error: " + e.getMessage(), e);
 }
   return true;
  }
  
 /**
 * 迭代模式 - 移除过期的 key
 * @param exceptKey
 */
 private void iterateRemoveExpiredCache(){
 long startTime = System.currentTimeMillis(); 
 
 int size = cacheMap.size();
 if(size ==0){
  return;
 }
 
 int keyCount = 0;
 int removedCount = 0 ;
 
 int startIndex = 0;
 int endIndex = 0;
 
 try{
  Object [] keys = cacheMap.keySet().toArray();
  keyCount = keys.length;
  int maxIndex = keyCount -1 ;
  
  //初始化扫描下标
  if(iterateScanAll){
  startIndex = 0;
  endIndex = maxIndex;
  }else {
  int gcThreshold = this.getGcThreshold();
  int iterateLen = gcThreshold > this.maxIterateSize &＃63; this.maxIterateSize : gcThreshold;
  
  startIndex = this.iterateLastIndex;
  startIndex = ( (startIndex <0 || startIndex > maxIndex) &＃63; 0 : startIndex );
  endIndex = (startIndex + iterateLen);
  endIndex = (endIndex > maxIndex &＃63; maxIndex : endIndex);
  }
  
  //迭代清理
  boolean flag = false;
  for(int i=startIndex; i<= endIndex; i++){
  flag = this.removeExpiredKey(keys[i]);
  if(flag){
   removedCount++;
  }
  }
  
  this.iterateLastIndex = endIndex;
  keys = null;
  
 }catch(Exception e){
  logger.error("iterateRemoveExpiredCache -- 移除过期的 key时出现异常: " + e.getMessage(), e);
 }
 
 long endTime = System.currentTimeMillis();
 
 StringBuffer sb = new StringBuffer();
 sb.append("iterateRemoveExpiredCache [ size: ").append(size).append(", keyCount: ").append(keyCount)
  .append(", startIndex: ").append(startIndex).append(", endIndex: ").append(iterateLastIndex)
  .append(", removedCount: ").append(removedCount).append(", currentSize: ").append(this.cacheMap.size())
  .append(", timeConsuming: ").append(endTime - startTime).append(", nowTime: ").append(new Date())
  .append(" ]");
 this.lastGCInfo = sb.toString();
 
 if(logger.isInfoEnabled()){
  logger.info("iterateRemoveExpiredCache -- 清理结果 -- "+ lastGCInfo);
 }
 }
 
 /**
 * 随机模式 - 移除过期的 key
 */
 private void randomRemoveExpiredCache(){
 long startTime = System.currentTimeMillis(); 
 
 int size = cacheMap.size();
 if(size ==0){
  return;
 }
 
 int removedCount = 0 ;
 try{
  Object [] keys = cacheMap.keySet().toArray();
  int keyCount = keys.length;
  
  boolean removeFlag = false;
  
  int removeRandomTimes = this.getGcThreshold();
  
  removeRandomTimes = ( removeRandomTimes > this.getMaxRandomTimes() &＃63; this.getMaxRandomTimes() : removeRandomTimes );
  while(removeRandomTimes-- > 0){
  
  int index = random.nextInt(keyCount);
  boolean flag = this.removeExpiredKey(keys[index]);
  if(flag){
   removeFlag = true;
   removedCount ++;
  }
  }
  //尝试 移除 首尾元素
  if(!removeFlag){
   this.removeExpiredKey(keys[0]);
   this.removeExpiredKey(keys[keyCount-1]);
  }
  keys=null;
  
 }catch(Exception e){
      logger.error("randomRemoveExpiredCache -- 移除过期的 key时出现异常: " + e.getMessage(), e);
 }
 long endTime = System.currentTimeMillis();
 
 StringBuffer sb = new StringBuffer();
 sb.append("randomRemoveExpiredCache [ size: ").append(size).append(", removedCount: ").append(removedCount)
  .append(", currentSize: ").append(this.cacheMap.size()).append(", timeConsuming: ").append(endTime - startTime)
  .append(", nowTime: ").append(new Date())
  .append(" ]");
 this.lastGCInfo = sb.toString();
 
 if(logger.isInfoEnabled()){
  logger.info("randomRemoveExpiredCache -- 清理结果 -- "+ lastGCInfo); 
 }
 }
 
 private boolean removeExpiredKey(Object key){
 boolean flag = false;
 
 CacheElement cacheObj = null;
 if(null != key){
  try{
  cacheObj = cacheMap.get(key);
  boolean isExpiredCache = this.isExpiredCache(cacheObj);
  if(isExpiredCache){
   cacheMap.remove(key);
   flag = true;
  }
  }catch(Exception e){
  logger.error("removeExpired(" + key + ") -- error: " + e.getMessage(), e);
  }
 }
 
 if(!flag && logGCDetail){
  this.logger.warn("removeExpiredKey(" + key + ") return [" + flag + "]--" + cacheObj);
 }
 
 return flag;
 }
 
 public int getInitialCapacity() {
 return initialCapacity;
 }

 public int getMaxCapacity() {
 return maxCapacity;
 }

 public int getGcMode() {
 return gcMode;
 }

 public void setGcMode(int gcMode) {
 this.gcMode = gcMode;
 }

 public int getGcIntervalTime() {
 return gcIntervalTime;
 }

 public void setGcIntervalTime(int gcIntervalTime) {
 this.gcIntervalTime = gcIntervalTime;
 }

 public boolean isEnableGC() {
 return enableGC;
 }

 public void setEnableGC(boolean enableGC) {
 this.enableGC = enableGC;
 }
 
 public boolean isIterateScanAll() {
 return iterateScanAll;
 }
 public void setIterateScanAll(boolean iterateScanAll) {
 this.iterateScanAll = iterateScanAll;
 }
 public float getGcFactor() {
 return gcFactor;
 }

 public void setGcFactor(float gcFactor) {
 this.gcFactor = gcFactor;
 }
 
 /**
 * gc 阀值
 * @return
 */
 public int getGcThreshold() {
 int threshold = (int)( this.cacheMap.getMaxCapacity() * gcFactor );
 return threshold;
 }

 public String getLastGCInfo() {
 return lastGCInfo;
 }

 public void setLastGCInfo(String lastGCInfo) {
 this.lastGCInfo = lastGCInfo;
 }
 
 public boolean isLogGCDetail() {
 return logGCDetail;
 }
 public void setLogGCDetail(boolean logGCDetail) {
 this.logGCDetail = logGCDetail;
 }
 public int getTimeout() {
 return timeout;
 }
 public void setTimeout(int timeout) {
 this.timeout = timeout;
 }
 public int getMaxIterateSize() {
 return maxIterateSize;
 }
 public void setMaxIterateSize(int maxIterateSize) {
 this.maxIterateSize = maxIterateSize;
 }
 public int getMaxRandomTimes() {
 return maxRandomTimes;
 }
 public void setMaxRandomTimes(int maxRandomTimes) {
 this.maxRandomTimes = maxRandomTimes;
 }
 public boolean isInitFlag() {
 return initFlag;
 }
 public long getDefaultLifeTime() {
 return defaultLifeTime;
 }

 public boolean isWarnLongerLifeTime() {
 return warnLongerLifeTime;
 }

 public void setWarnLongerLifeTime(boolean warnLongerLifeTime) {
 this.warnLOngerLifeTime= warnLongerLifeTime;
 }

 //======================== dynMaxCapacity ========================
 private int dynMaxCapacity = maxCapacity;
 public int getDynMaxCapacity() {
 return dynMaxCapacity;
 }
 public void setDynMaxCapacity(int dynMaxCapacity) {
 this.dynMaxCapacity = dynMaxCapacity;
 }
 public void resetMaxCapacity(){
 if(dynMaxCapacity > initialCapacity && dynMaxCapacity != maxCapacity){
  
  if(logger.isInfoEnabled()){
  logger.info("resetMaxCapacity( " + dynMaxCapacity + " ) start...");
  }
  
  synchronized(cacheMap){
  LRULinkedHashMap cacheMap0 = new LRULinkedHashMap(initialCapacity ,dynMaxCapacity);
  cacheMap.clear();
  cacheMap = cacheMap0;
  this.maxCapacity = dynMaxCapacity;
  }
  
  if(logger.isInfoEnabled()){
  logger.info("resetMaxCapacity( " + dynMaxCapacity + " ) OK.");
  }
 }else {
  if(logger.isWarnEnabled()){
  logger.warn("resetMaxCapacity( " + dynMaxCapacity + " ) NO.");
  }
 }
 }
 //======================== showCacheElement ========================
 private String showCacheKey;
 public String getShowCacheKey() {
 return showCacheKey;
 }
 public void setShowCacheKey(String showCacheKey) {
 this.showCacheKey = showCacheKey;
 }
 public Object showCacheElement(){
 Object v = null;
 
 if(null != this.showCacheKey){
  v = cacheMap.get(showCacheKey);
 }
 
 return v;
 }
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

ios
容器

推荐阅读

服务器
ASP11：深入解析与应用展望

ASP11：深入解析与应用展望本文详细探讨了 ASP11 中的 `AppRelativeTemplateSourceDirectory` 属性，该属性用于获取或设置包含控件的 Page 或 UserControl 对象的应用程序相对虚拟目录。此外，文章还介绍了 1.0 版本中的 Binding 机制，分析了其在实际开发中的应用和优化方法，为开发者提供了全面的技术指导。 ... [详细]

蜡笔小新 2024-11-02 09:56:29
容器
第2周：高精度计算（支持任意进制，仅需调整基数）+ 前缀和 + 差分技术

本周课程涵盖了高精度计算、前缀和及差分技术。在高精度计算部分，我们将探讨如何处理任意进制的数值运算，包括但不限于正数的加法、减法和乘法。通过调整基数，可以灵活应对不同进制的需求。前缀和与差分技术则主要用于高效解决数组和区间查询问题，提升算法性能。 ... [详细]

蜡笔小新 2024-11-01 17:46:37
容器
开发笔记：STL 容器 deque 的元素访问与迭代器详解

开发笔记：STL 容器 deque 的元素访问与迭代器详解 ... [详细]

蜡笔小新 2024-11-01 13:44:43
容器
Java集合框架特性详解与开发实践笔记

Java集合框架特性详解与开发实践笔记 ... [详细]

蜡笔小新 2024-11-02 12:55:56
容器
基于.NET框架的分层架构实践（六）：依赖注入与IoC容器的设计和实现详解

在基于.NET框架的分层架构实践中，为了实现各层之间的松散耦合，本文详细探讨了依赖注入（DI）和控制反转（IoC）容器的设计与实现。通过合理的依赖管理和对象创建，确保了各层之间的单向调用关系，从而提高了系统的可维护性和扩展性。此外，文章还介绍了几种常见的IoC容器实现方式及其应用场景，为开发者提供了实用的参考。 ... [详细]

蜡笔小新 2024-11-02 11:16:33
容器
iOS设备调试指南：Xcode 8.0及以上版本适用（2015年更新）

本文提供了针对iOS设备在Xcode 8.0及以上版本中的调试指南，详细介绍了从环境配置到常见问题解决的全流程。内容涵盖设备连接、证书配置、日志查看及性能监控等多个方面，适用于2015年后的开发环境。通过本指南，开发者可以高效地进行应用调试，提升开发效率。 ... [详细]

蜡笔小新 2024-11-02 10:39:34
容器
【并发编程】全面解析 Java 内存模型，一篇文章带你彻底掌握

本文深入解析了 Java 内存模型（JMM），从基础概念到高级特性进行全面讲解，帮助读者彻底掌握 JMM 的核心原理和应用技巧。通过详细分析内存可见性、原子性和有序性等问题，结合实际代码示例，使开发者能够更好地理解和优化多线程并发程序。 ... [详细]

蜡笔小新 2024-11-02 09:09:51
service
D2iQ与Rafay联手打造统一的应用与基础设施管理解决方案

D2iQ与Rafay合作推出了一种全面的应用和基础设施管理解决方案。本文深入探讨了双方如何通过集成技术实现统一管理，为面临类似挑战的企业提供详细的分析和实用建议，助力其高效管理和优化资源。 ... [详细]

蜡笔小新 2024-11-01 20:19:50
port
使用CardView实现圆角和圆形效果：边角与半径的精准控制

使用CardView实现圆角和圆形效果：边角与半径的精准控制 ... [详细]

蜡笔小新 2024-11-01 18:45:01
容器
如何在Spark数据排序过程中有效避免内存溢出（OOM）问题

本文深入探讨了在使用Spark进行数据排序时如何有效预防内存溢出（OOM）问题。通过具体的代码示例，详细阐述了优化策略和技术手段，为读者在实际工作中遇到类似问题提供了宝贵的参考和指导。 ... [详细]

蜡笔小新 2024-11-01 16:55:53
容器
Kubernetes中为容器设置主机名解析配置

在某些特定场景中，例如请求的域名为内部网络域名或需要通过透明代理/正向代理才能访问时，容器无法直接使用宿主机的 hosts 文件。为了实现主机名解析，可以在 Kubernetes 的 Pod YAML 文件中定义 hosts 条目，从而确保容器能够正确解析所需的主机名。 ... [详细]

蜡笔小新 2024-11-01 11:20:47
容器
Java集合框架的使用方法与性能对比分析

本文详细探讨了Java集合框架的使用方法及其性能特点。首先，通过关系图展示了集合接口之间的层次结构，如`Collection`接口作为对象集合的基础，其下分为`List`、`Set`和`Queue`等子接口。其中，`List`接口支持按插入顺序保存元素且允许重复，而`Set`接口则确保元素唯一性。此外，文章还深入分析了不同集合类在实际应用中的性能表现，为开发者选择合适的集合类型提供了参考依据。 ... [详细]

蜡笔小新 2024-11-01 09:51:38
容器
C语言中按位取反与按位与运算符的使用方法及应用场景解析

位运算是一种基于二进制的计算方式，在系统软件开发中经常用于处理二进制位的相关问题。C语言提供了六种位操作运算符，专门用于对整型数据（包括带符号和无符号的char、short等）进行操作。本文详细解析了按位取反和按位与运算符的使用方法及其典型应用场景，帮助开发者更好地理解和应用这些运算符。 ... [详细]

蜡笔小新 2024-10-31 19:06:08
容器
基于POI的Java Maven项目中实现Excel数据的高效导入与导出功能

本项目在Java Maven框架下，利用POI库实现了Excel数据的高效导入与导出功能。通过优化数据处理流程，提升了数据操作的性能和稳定性。项目已发布至GitHub，当前最新版本为0.0.5。该项目不仅适用于小型应用，也可扩展用于大型企业级系统，提供了灵活的数据管理解决方案。GitHub地址：https://github.com/83945105/holygrail，Maven坐标：`com.github.83945105:holygrail:0.0.5`。 ... [详细]

蜡笔小新 2024-10-31 18:52:27
容器
深入解析 Vue 中通过 $route.params 实现参数传递的方法与技巧

本文深入探讨了在 Vue 框架中利用 `$route.params` 进行参数传递的方法和技巧。通过详细解析 `$route.params` 的工作机制及其与 `$route.query` 的区别，帮助开发者更好地理解和应用这一功能。文章不仅涵盖了基本的使用方法，还提供了实际案例和最佳实践，以便读者能够灵活运用这些技术，提升开发效率和代码质量。 ... [详细]

蜡笔小新 2024-10-31 17:59:47

蘑菇宝

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章