@Component
public class Cache {

    private static final Logger log = LoggerFactory.getLogger(Cache.class);

//    缓存结构
    private final Set<Integer> cache = new HashSet<>();

//    读写锁，防止线程不安全
    private final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();

    private final  Lock readLock = lock.readLock();

    private final Lock writeLock = lock.writeLock();

//    初始化缓存
    public void initCache(){

        for(int i=0;i<3;i++){
            if(i%2 == 0){
                cache.add(i);
            }
        }
    }

//  缓存更新
    public boolean updateCache(int number){
        try {
            writeLock.lock();
            cache.add(number);
            System.out.print("数据更新成功，正在休眠.......缓存数据为:");
            cache.stream().forEach(System.out::println);
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            log.info("缓存数据更新失败:"+number);
            e.printStackTrace();
            return false;
        }finally {
            writeLock.unlock();
        }
        return true;
    }

//    读缓存判断
    public boolean isContain(int num){

        try {
            readLock.lock();
            if(cache.contains(num)){
                return true;
            }else {
                return false;
            }
        }finally {
            readLock.unlock();
        }
    }
}