1 回答
TA贡献1898条经验 获得超8个赞
如果您使用的是桌面设备,您可以查看 Google Guava,它有许多缓存实用程序,包括创建具有逐出时间的条目的功能。使用它,您可以添加条目并驱逐 10 分钟。然后,当新的 JSON 进来时,您可以检查它是否存在于缓存中。如果不是,则发送通知,如果是,则重新设置驱逐时间。
您也可以编写自己的 EvictionMap。扩展ConcurrentHashMap,并在构造函数中创建一个线程并启动它。在线程内部,您可以检查 X 秒(听起来像是每 5 秒一次)并逐出条目。地图需要 <User, long>,其中 long 是驱逐时间。您可以创建自己的 put() 和 get() 以及可能的 touch() ,这会将驱逐时间重置为 System.getCurrentMillis();
(我刚刚找到了几年前使用过的版本。它可以在管理线程的方式上进行一些改进)
import java.util.Iterator;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
public class EvictionList<K>
{
private final ConcurrentHashMap<K, Long> evictionList = new ConcurrentHashMap<K, Long>();
private long evictionTime;
private final EvictionThread t;
public EvictionList(int evictionTimeInSeconds)
{
this.evictionTime = evictionTimeInSeconds * 1000;
t = new EvictionThread(this, evictionTime);
Thread thread = new Thread(t);
thread.start();
}
public void touch(K o)
{
evictionList.put(o, System.currentTimeMillis());
}
public void evict()
{
long current = System.currentTimeMillis();
for (Iterator<K> i=evictionList.keySet().iterator(); i.hasNext();)
{
K k = i.next();
if (current > (evictionList.get(k) + evictionTime) )
{
i.remove();
}
}
}
public void setEvictionTime(int timeInSeconds)
{
evictionTime = timeInSeconds * 1000;
t.setEvictionTime(evictionTime);
}
public Set<K> getKeys()
{
return evictionList.keySet();
}
public void stop()
{
t.shutDown();
}
@Override
protected void finalize()
{
t.shutDown();
}
private class EvictionThread implements Runnable
{
private volatile long evictionTime;
private EvictionList list;
private volatile boolean shouldRun = true;
private EvictionThread(EvictionList list, long evictionTime)
{
this.list = list;
this.evictionTime = evictionTime;
}
public void shutDown()
{
shouldRun = false;
}
public void setEvictionTime(long time)
{
evictionTime = time;
}
public void run()
{
while (shouldRun)
{
try
{
Thread.sleep(evictionTime);
}
catch (Exception ex) {}
list.evict();
}
}
}
}
添加回答
举报