cacheserviceimpl.java

GridSphere 门户 提供一个基于 portlet 的高级开放源代码门户。GridSphere 是在欧盟提供基金的 GridLab 项目下开发的

/**
 * @author <a href="mailto:[e-mail]">Gergely Kis</a>
 * @author <a href="mailto:[e-mail]">Jason Novotny</a>
 * @version $Id: CacheServiceImpl.java 4496 2006-02-08 20:27:04Z wehrens $
 */
package org.gridsphere.services.core.cache.impl;

import org.gridsphere.portlet.service.PortletServiceUnavailableException;
import org.gridsphere.portlet.service.spi.PortletServiceConfig;
import org.gridsphere.portlet.service.spi.PortletServiceProvider;
import org.gridsphere.services.core.cache.CacheService;

import java.util.*;

/**
 * Simple CacheService implementation
 */
public class CacheServiceImpl implements PortletServiceProvider, CacheService {

    private Map key2object = null;
    private boolean isCachingOn = true;

    private class CacheSweeperTask extends TimerTask {

        public void run() {
            clearExpiredEntries();
        }

    }

    private static class CacheObject {
        public String key;
        public boolean rolling;
        public long expiration;
        public long delay;
        public Object cached;

        public CacheObject(String key, Object cached, long delay) {
            this.key = key;
            this.cached = cached;
            this.delay = delay;
            this.expiration = System.currentTimeMillis() + delay;
        }

        public void rollExpiration() {
            if (rolling) {
                this.expiration = System.currentTimeMillis() + delay;
            }
        }
    }

    public synchronized void init(PortletServiceConfig config) throws PortletServiceUnavailableException {
        String isCachingOnStr = config.getInitParameter("isCachingOn");
        if (!isCachingOnStr.equals("true") &&
                !isCachingOnStr.equals("t") &&
                !isCachingOnStr.equals("yes") &&
                !isCachingOnStr.equals("y")) {
            isCachingOn = false;
        }
        
        key2object = new HashMap();
        Timer timer = new Timer(true);
        timer.schedule(new CacheSweeperTask(),  Calendar.getInstance().getTime(), 1000 * 60 ); // 1 minute intervals

    }

    public synchronized void destroy() {
        key2object.clear();
    }

    public synchronized void cache(String key, Object object, long timeout) {
        if (isCachingOn)
            key2object.put(key.intern(), new CacheObject(key.intern(), object, timeout));
    }

    public synchronized Object getCached(String key) {
        if (isCachingOn) {
            CacheObject cobj = (CacheObject) key2object.get(key.intern());
            if (cobj != null) {
                cobj.rollExpiration();
                return cobj.cached;
            }
        }
        return null;
    }

    protected synchronized void clearExpiredEntries() {
        //log.debug("Updating render cache");
        Set expiredKeys = new HashSet();
        Iterator cacheIter = key2object.values().iterator();
        long currentTime = System.currentTimeMillis();
        while (cacheIter.hasNext()) {
            CacheObject cobj = (CacheObject) cacheIter.next();
            if ((cobj.delay > 0) && (cobj.expiration < currentTime)) {
                expiredKeys.add(cobj.key);
            }
        }
        Iterator keyIter = expiredKeys.iterator();
        while (keyIter.hasNext()) {
            key2object.remove(keyIter.next());
        }
    }

    public synchronized void removeCached(String key) {
        if (isCachingOn)
            key2object.remove(key.intern());
    }

}