cachefreshtask.java

定制缓存的生命周期

package zhouyouguo.slack;

import java.util.*;
import java.util.Map.Entry;

class CacheFreshTask extends TimerTask {
    private DefaultCache cache;
    public CacheFreshTask(DefaultCache cache) {
        this.cache = cache;
    }

    public void run() {
        synchronized (cache.datas) {
            Iterator iterator = cache.datas.entrySet().iterator();
            if(iterator!=null){
		        while (iterator.hasNext()) {
		        	Map.Entry entry = (Entry) iterator.next();
		            SimpleCacheInfo sci = (SimpleCacheInfo) entry.getValue();
		            if (sci.getSecondsTotal() != ICacheInterface.Forever) {
		            	System.out.println(sci.getObj().toString());
		                sci.setSecondsRemain(sci.getSecondsRemain() - DefaultCache.FreshTimerIntervalSeconds);
		                if (sci.getSecondsRemain() <= 0) {
		                    iterator.remove();
		                }
		            }
		        }
            }
        }
    }
}