前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >java代码薄:常用的缓存

java代码薄:常用的缓存

作者头像
cosmozhu
发布2020-06-15 06:43:32
5430
发布2020-06-15 06:43:32
举报
文章被收录于专栏:cosmozhu技术篇cosmozhu技术篇

现在的项目中应该基本都用redis做缓存了,本文提供一个简单的线程安全缓存类,提供超时淘汰策略。方便没必要引进第三方缓存时使用。

一个简单的缓存

代码语言:javascript
复制
import java.time.LocalDateTime;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;

/**
 * 一个简单的基于时间淘汰的缓存-线程安全
 * 
 * @author cosmozhu
 * @mail zhuchao1103@gmail.com
 * @site https://www.cosmozhu.fun
 */
public class NormalCache {
    private final static Map<Object, NormalCache.Entry> cache = new ConcurrentHashMap<Object, NormalCache.Entry>(16);
    // 超时时间单位是秒
    private static int timeout = -1;
    // 检查缓存周期单位是秒
    private static int checkCycle = 60;

    private NormalCache() {
    }

    static {
        Thread daemonThread = new Thread(() -> {
            while (true) {
                try {
                    TimeUnit.SECONDS.sleep(checkCycle);
                    for (Map.Entry<Object, NormalCache.Entry> entry : cache.entrySet()) {
                        // 淘汰数据
                        eliminate(entry.getKey(), entry.getValue(), entry.getValue().timeStamp);
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

            }
        });
        daemonThread.setDaemon(true);
        daemonThread.setName("NormalCache Daemon Thread");
        daemonThread.start();
    }

    private static void eliminate(Object key, NormalCache.Entry value, LocalDateTime timeStamp) {
        if (timeout > 0 && !value.isHold && LocalDateTime.now().compareTo(timeStamp.plusSeconds(timeout)) > 0) {
            cache.remove(key);
        }
    }

    /**
     * 放入缓存数据
     * 
     * @param key   缓存键
     * @param value 缓存数据
     */
    public static <K, V> void put(K key, V value) {
        cache.put(key, new NormalCache.Entry<V>(LocalDateTime.now(), value, false));
    }

    /**
     * 放入缓存数据-不会被超时淘汰
     * 
     * @param key   缓存键
     * @param value 缓存数据
     */
    public static <K, V> void putHold(K key, V value) {
        cache.put(key, new NormalCache.Entry<V>(LocalDateTime.now(), value, true));
    }

    public static <K, V> V get(K key) {
        NormalCache.Entry entry = cache.get(key);
        eliminate(key, entry, entry.timeStamp);
        return (V) cache.get(key).value;
    }

    public static <K, V> V remove(K key) {
        return (V) cache.remove(key).value;
    }

    /**
     * 获取数据超时时间
     * 
     * @return
     */
    public static int getTimeout() {
        return timeout;
    }

    /**
     * 设置数据超时时间-单位为s
     * 
     * @param timeout 超时时间应设置大于0的数,默认为-1不进行数据淘汰
     */
    public static void setTimeout(int timeout) {
        NormalCache.timeout = timeout;
    }

    /**
     * 获取缓存过期数据检查周期单位为秒
     * 
     * @return 缓存过期数据检查周期单位为秒
     */
    public static int getCheckCycle() {
        return checkCycle;
    }

    /**
     * 设置缓存过期数据检查周期单位为秒
     * 
     * @param checkCycle 设置缓存过期数据检查周期单位为秒-整数
     */
    public static void setCheckCycle(int checkCycle) {
        NormalCache.checkCycle = checkCycle;
    }

    private static class Entry<V> {
        private LocalDateTime timeStamp;
        private V value;
        private boolean isHold;

        public Entry(LocalDateTime timeStamp, V value, boolean isHold) {
            this.timeStamp = timeStamp;
            this.value = value;
            this.isHold = isHold;
        }

        @Override
        public String toString() {
            return "entry [timeStamp=" + timeStamp + ", value=" + value + "]";
        }
    }
}

作者:cosmozhu --90后的老父亲,专注于保护地球的程序员

个人网站:https://www.cosmozhu.fun

欢迎转载,转载时请注明出处。

相关文章

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 一个简单的缓存
    • 相关文章
    相关产品与服务
    对象存储
    对象存储(Cloud Object Storage,COS)是由腾讯云推出的无目录层次结构、无数据格式限制,可容纳海量数据且支持 HTTP/HTTPS 协议访问的分布式存储服务。腾讯云 COS 的存储桶空间无容量上限,无需分区管理,适用于 CDN 数据分发、数据万象处理或大数据计算与分析的数据湖等多种场景。
    领券
    问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档