最近碰到了本地緩存，查閱了一下資料使用currentHashMap實現了一個帶timeout的本地緩存，
直接上代碼：
package local.cache;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
public class LocalCache {
private LocalCache() {
}
// 測試為public，實際使用應該改為private
public static final Map<String, ValueObject> localCache = new ConcurrentHashMap<String, ValueObject>();
static {
// 初始化
// Test
for(int i = 1;i<11;i++) {
System.out.println(LocalCache.set(String.valueOf(i),i +"-value", 3000));
}
}
private static class ValueObject {
private String value;
private long timeout;
private ValueObject(String value, long timeout) {
super();
this.value = value;
this.timeout = timeout;
}
private String getValue() {
return value;
}
private long getTimeout() {
return timeout;
}
}
public static String set(String key, String value, long timeout) {
long currentTime = System.currentTimeMillis();
ValueObject valueObject = localCache.get(key);
if (localCache.keySet().contains(key) && (valueObject.getTimeout() == 0 ||currentTime <= valueObject.getTimeout())) {
return valueObject.getValue();
} else {
ValueObject oldValueObject = localCache.put(key,new ValueObject(value,currentTime + timeout));
return oldValueObject == null ? null : oldValueObject.getValue();
}
}
public static String set(String key, String value) {
ValueObject oldValueObject = localCache.put(key,new ValueObject(value, 0));
return oldValueObject == null ? null : oldValueObject.getValue();
}
public static String get(String key) {
long currentTime = System.currentTimeMillis();
ValueObject valueObject = localCache.get(key);
if (valueObject == null) {
return null;
}
if (valueObject.getTimeout() == 0 || currentTime <= valueObject.getTimeout()) {
return valueObject.getValue().toString();
} else {
localCache.remove(key);
return null;
}
}
}
測試：
package local.cache;
public class Client {
public static void main(String[] args) {
System.out.println(LocalCache.localCache);//為了使static（field，block，method） 運行（初始化），初始化順序為代碼聲明的順序
// 實際使用時只有LocalCache.set和LocalCache.get暴露出來，所以調用這兩個方法的時候，localCache和靜態塊已經先行初始化了
try {
Thread.sleep(3001);// 本來使用的是3000，但是輸出有問題，有些預想已經過時的卻仍舊能夠取得到，估計是jvm運行優化導致的
} catch (InterruptedException e) {
e.printStackTrace();
}
for(int i = 1;i < 11;i++) {
System.out.println(i +":"+ LocalCache.get(String.valueOf(i)));
}
}
}
currentHashMap這個實現類在多線程情況下，有一個類似行級讀寫鎖功能，可以另行查閱一下。
所以這個也就實現了並發的安全性。