zoukankan      html  css  js  c++  java
  • Guava Cache 参数配置说明

    系统中用到了了Guava Cache:

     private DriverInfoServiceImpl(DriverClientProxy driverClientProxy) {
            this.driverClientProxy = driverClientProxy;
            this.driverCacheLoader = new DriverCacheLoader(driverClientProxy);
            loadingCache = CacheBuilder
                    .newBuilder()
                    .concurrencyLevel(5)
                    .recordStats()
                    .expireAfterWrite(1, TimeUnit.MINUTES)
                    .build(driverCacheLoader);
        }

     相应的参数解释:

    concurrencyLevel(5) ==并发度,可以同时写缓存的线程数。
    recordStats==设置要统计缓存的命中率;
    expireAfterWrite(
    1, TimeUnit.MINUTES);设置写缓存后,1分钟过期
      public static void main(String[] args) throws ExecutionException, InterruptedException{
            //缓存接口这里是LoadingCache,LoadingCache在缓存项不存在时可以自动加载缓存
            LoadingCache<Integer,Student> studentCache
                    //CacheBuilder的构造函数是私有的,只能通过其静态方法newBuilder()来获得CacheBuilder的实例
                    = CacheBuilder.newBuilder()
                    //设置并发级别为8,并发级别是指可以同时写缓存的线程数
                    .concurrencyLevel(8)
                    //设置写缓存后8秒钟过期
                    .expireAfterWrite(8, TimeUnit.SECONDS)
                    //设置缓存容器的初始容量为10
                    .initialCapacity(10)
                    //设置缓存最大容量为100,超过100之后就会按照LRU最近虽少使用算法来移除缓存项
                    .maximumSize(100)
                    //设置要统计缓存的命中率
                    .recordStats()
                    //设置缓存的移除通知
                    .removalListener(new RemovalListener<Object, Object>() {
                        @Override
                        public void onRemoval(RemovalNotification<Object, Object> notification) {
                            System.out.println(notification.getKey() + " was removed, cause is " + notification.getCause());
                        }
                    })
                    //build方法中可以指定CacheLoader,在缓存不存在时通过CacheLoader的实现自动加载缓存
                    .build(
                            new CacheLoader<Integer, Student>() {
                                @Override
                                public Student load(Integer key) throws Exception {
                                    System.out.println("load student " + key);
                                    Student student = new Student();
                                    student.setId(key);
                                    student.setName("name " + key);
                                    return student;
                                }
                            }
                    );
    
            for (int i=0;i<20;i++) {
                //从缓存中得到数据,由于我们没有设置过缓存,所以需要通过CacheLoader加载缓存数据
                Student student = studentCache.get(1);
                System.out.println(student);
                //休眠1秒
                TimeUnit.SECONDS.sleep(1);
            }
    
            System.out.println("cache stats:");
            //最后打印缓存的命中率等 情况
            System.out.println(studentCache.stats().toString());
        }

    参考:使用google guava做内存缓存

  • 相关阅读:
    数组有没有length()这个方法? String有没有length()这个方法?
    序列化接口的id有什么用?
    如何进行Hibernate的性能优化?
    构造器Constructor是否可被override?
    Collection框架中实现比较要实现什么接口?
    ArrayList如何实现插入的数据按自定义的方式有序存放?
    Java中会存在内存泄漏吗,请简单描述?
    List 和 Map 区别?
    面向对象的特征有哪些?
    垃圾回收器的基本原理是什么?垃圾回收器可以马上回收内存吗?有什么办法主动通知虚拟机进行垃圾回收?
  • 原文地址:https://www.cnblogs.com/aspirant/p/11188851.html
Copyright © 2011-2022 走看看