马老师RocketMQ源码深入剖析
errorExceptionCache.refresh(key);
Map<Integer, AtomicInteger> map = MapUtil.builder(500, new AtomicInteger())
.put(400, new AtomicInteger()).put(300, new AtomicInteger()).build();
errorExceptionCache.putAll(map);
System.out.println("in removal listener," + key + "\t" + errorExceptionCache.get(key));
}
}).build(key -> {
System.out.println("load方法调用: " + key);
return new AtomicInteger(key);
