package com.sf.aging.control.cache;

import com.sf.ops.flow.google.common.base.Optional;

import com.sf.ops.flow.google.common.cache.CacheBuilder;

import com.sf.ops.flow.google.common.cache.CacheLoader;

import com.sf.ops.flow.google.common.cache.LoadingCache;

import java.util.concurrent.TimeUnit;

/**

* 未发未提明细运单状态缓存服务:

*/

public class LocalCacheNosendPickDetailService {

private static LoadingCache<String, Optional<Integer>> wayBillRouteStatCache = CacheBuilder.newBuilder()

//设置并发级别为10，并发级别是指可以同时写缓存的线程数

.concurrencyLevel(10)

// //设置写缓存后60分钟没有写操作就重新加载(异步,不阻塞)

// .refreshAfterWrite(60, TimeUnit.MINUTES)

//设置写缓存后6小时没有写操作就失效

.expireAfterWrite(6, TimeUnit.HOURS)

//设置缓存容器的初始容量为50万

.initialCapacity(50 * 10000)

//设置缓存最大容量为500万，超过200万之后就会按照LRU最近虽少使用算法来移除缓存项

.maximumSize(500 * 10000L)

//设置要统计缓存的命中率

.recordStats()

//设置缓存的移除通知

.build(//build方法中可以指定CacheLoader，在缓存不存在时通过CacheLoader的实现自动加载缓存

new CacheLoader<String, Optional<Integer>>() {

@Override

public Optional<Integer> load(String key) {

return Optional.fromNullable(null);

}

}

);

public Integer getCacheValue(String waybillNo) {

return wayBillRouteStatCache.getUnchecked(waybillNo).orNull();

}

public void updateCacheValue(String waybillNo, Integer exceptionType) {

wayBillRouteStatCache.put(waybillNo, Optional.of(exceptionType));

}

public void invalidate(String waybillNo) {

wayBillRouteStatCache.invalidate(waybillNo);

}

}