import java.util.Collections; import java.util.HashMap; import java.util.Map; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; public class SimpleCache{ private final Map m_objects; private final Map m_expiredObjects; private final long m_lExpireTime; private final ExecutorService m_executor; public SimpleCache() { this(500); } public SimpleCache(final int nExpireTime) { m_objects = Collections.synchronizedMap(new HashMap ()); m_expiredObjects = Collections.synchronizedMap(new HashMap ()); m_lExpireTime = nExpireTime; m_executor = Executors.newFixedThreadPool(256); Executors.newScheduledThreadPool(5).scheduleWithFixedDelay(RemoveExpiredObjects(), m_lExpireTime / 2, m_lExpireTime, TimeUnit.SECONDS); } private final Runnable RemoveExpiredObjects() { return new Runnable() { public void run() { for (final String name : m_expiredObjects.keySet()) { if (System.currentTimeMillis() > m_expiredObjects.get(name)) { m_executor.execute(CreateRemoveRunnable(name)); } } } }; } private final Runnable CreateRemoveRunnable(final String name) { return new Runnable() { public void run() { m_objects.remove(name); m_expiredObjects.remove(name); } }; } public long GetExpireTime() { return m_lExpireTime; } public void Put(final String name, final T obj) { Put(name, obj, m_lExpireTime); } public void Put(final String name, final T obj, final long expireTime) { m_objects.put(name, obj); m_expiredObjects.put(name, System.currentTimeMillis() + expireTime * 1000); } public T Get(final String name) { final Long expireTime = m_expiredObjects.get(name); if (expireTime == null) return null; if (System.currentTimeMillis() > expireTime) { m_executor.execute(CreateRemoveRunnable(name)); return null; } return m_objects.get(name); } @SuppressWarnings("unchecked") public R Get(final String name, final Class type) { return (R) Get(name); } }
0
0
相关文章
在Java中异常体系的设计初衷是什么_Java错误处理机制说明
RxJava 中高效处理多字段差异更新的流合并策略
如何在 macOS 上正确运行 Java TCP 服务器/客户端通信程序
在8×8井字棋中高效检测五连珠获胜条件的完整实现教程
Android ListView 初始化错误导致应用崩溃的解决方案
java速学教程(入门到精通)
下载
java怎么学习?java怎么入门?java在哪学?java怎么学才快?不用担心,这里为大家提供了java速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!
本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
热门AI工具









