美文网首页
基于读写锁实现一个内存缓存器

基于读写锁实现一个内存缓存器

作者: 杜子龙 | 来源:发表于2019-01-19 20:48 被阅读0次

首先实现定时任务读取数据库信息到内存:

public class ScheduledTask {

    @Autowired
    private TestMapper testMapper;

    @Autowired
    private ScheduledTaskImpl scheduledTaskImpl;

    /**
     * Cron表达式由6~7项组成,中间用空格分开。从左到右依次是:秒、分、时、日、月、周几、年(可省略)。值可以是数字,也可以是以下符号:
     * :所有值都匹配
     * ? :无所谓,不关心,通常放在“周几”里
     * , :或者
     * / :增量值
     * - :区间
     */

    private static ExecutorService executorService;

    public static ExecutorService getExecutorService() {
        if (null == executorService) {
            executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
        }
        return executorService;

    }

    @Scheduled(cron = "0 5/5 * * * ?  ")
    public void executeCompanyCodeTask() {
        getExecutorService().execute(new Runnable() {
            @Override
            public void run() {
                try {
                    Map<Long, Test> idMap = new HashMap<>();
                    List<Test> list = testMapper.selectAll();
                    for(Test test: list){
                        idMap.put(test.getId(), object);
                    }
                scheduledTaskImpl.setIdMap(idMap);
                } catch (Exception e) {
                    e.printStackTrace();
                    log.error("更新信息出错", e);
                }
            }
        });
    }
}

接下来就是从内存中取数据:

public class ScheduledTaskImpl {

    @Autowired
    private TestfMapper testMapper;

    private Map<Long, Test> idMap = new HashMap<>();

    private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();

    public void setIdMap(Map idMap){
        lock.writeLock().lock();//上写锁,不允许其他线程读也不允许写
        this.idMap = idMap;
        lock.writeLock().unlock();//释放写锁
    }

    public Test getById(Long id){
        Test test = null;
        lock.readLock().lock();//首先开启读锁,从缓存中去取
        try {
            test = idMap.get(id);
            if (test == null) {//如果缓存中没有释放读锁,上写锁
                lock.readLock().unlock();
                lock.writeLock().lock();
                try {
                    if(test == null){
                        test = testMapper.selectById(id);
                        if (test == null) {
                            throw new RuntimeException("数据不存在");
                        }
                        idMap.put(id, test);
                    }
                }finally {
                    lock.writeLock().unlock();//释放写锁
                }
                lock.readLock().lock();//然后再上读锁
            }
        }catch (Exception e) {
            log.error("根据id获取数据出错," + e.getMessage());
        } finally {
            lock.readLock().unlock();//最后释放读锁
        }
        return test;
    }
}

参考博客:
1.https://www.jianshu.com/p/840b55ef4186
2.https://www.cnblogs.com/zzlp/p/5174745.html

相关文章

  • 基于读写锁实现一个内存缓存器

    上一个用java实现的版本,这里用go也实现了一遍:

  • 基于读写锁实现一个内存缓存器

    首先实现定时任务读取数据库信息到内存: 接下来就是从内存中取数据: 参考博客:1.https://www.jian...

  • YYCache 源码流程

    存储技术 基于文件读写 基于 mmap 文件内存映射 基于数据库 基于文件系统 SDWebImage 等缓存:一个...

  • 分布式锁实现

    基于数据库实现分布式锁基于缓存(redis,memcached)实现分布式锁基于Zookeeper实现分布式锁 s...

  • 基于redis的分布式锁

    分布式锁实现方案 基于数据库实现分布式锁 基于缓存(redis,memcached,tair)实现分布式锁 基于Z...

  • 分布式锁

    几种实现方式 基于数据库实现分布式锁 基于缓存(Redis,memcached,tair)实现分布式锁 基于Zoo...

  • 17.读写锁ReentrantWriteReadLock

    读写锁ReentrantWriteReadLock,基于AQS的锁机制,实现ReadWriteLock接口。内部有...

  • 分布式锁的实现方案

    一,分布式锁的实现方案 1,基于数据库实现分布式锁 2,基于缓存实现数据库锁(redis) 3,基于zookeep...

  • redis学习笔记(八) 缓存设计

    1. 缓存优缺点 缓存常用的结构如下: 1.1. 优点 加速读写:由于数据库读写速度慢,而基于内存的读写速度快,所...

  • 分布式锁的实现-Redisson

    常见3种分布式的实现比较 基于数据库实现分布式锁 基于缓存实现分布式锁(redis,mc) 基于Zookeeper...

网友评论

      本文标题:基于读写锁实现一个内存缓存器

      本文链接:https://www.haomeiwen.com/subject/bcjzdqtx.html