馬老師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方法調(diào)用: " + key);
? ? ? ? ? ? ? ? ? ?return new AtomicInteger(key);
標(biāo)簽：
