✅ Adding tests.

crossoverJie · crossoverJie · commit a59792b04d65 · 2018-06-13T00:29:19.000+08:00
diff --git a/src/main/java/com/crossoverjie/guava/CacheLoaderTest.java b/src/main/java/com/crossoverjie/guava/CacheLoaderTest.java
@@ -3,6 +3,7 @@
 import com.google.common.cache.CacheBuilder;
 import com.google.common.cache.CacheLoader;
 import com.google.common.cache.LoadingCache;
+import com.google.common.collect.Interner;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -20,8 +21,8 @@
  */
 public class CacheLoaderTest {
     private final static Logger LOGGER = LoggerFactory.getLogger(CacheLoaderTest.class);
-    private LoadingCache<Long, AtomicLong> loadingCache ;
-    private final static Long KEY = 1L;
+    private LoadingCache<Integer, AtomicLong> loadingCache ;
+    private final static Integer KEY = 1000;
 
 
     private final static LinkedBlockingQueue<Integer> QUEUE = new LinkedBlockingQueue<>(1000);
@@ -30,29 +31,34 @@ public class CacheLoaderTest {
     private void init() throws InterruptedException {
         loadingCache = CacheBuilder.newBuilder()
                 .expireAfterWrite(2, TimeUnit.SECONDS)
-                .build(new CacheLoader<Long, AtomicLong>() {
+                .maximumSize(3)
+
+                .build(new CacheLoader<Integer, AtomicLong>() {
                     @Override
-                    public AtomicLong load(Long key) throws Exception {
-                        return new AtomicLong(0L);
+                    public AtomicLong load(Integer key) throws Exception {
+                        return new AtomicLong(0);
                     }
                 });
 
 
-        for (int i = 0; i < 5; i++) {
+        for (int i = 10; i < 15; i++) {
             QUEUE.put(i);
         }
     }
 
-    private void checkAlert() {
+    private void checkAlert(Integer integer) {
         try {
 
+            loadingCache.put(integer,new AtomicLong(integer));
+
+            //TimeUnit.SECONDS.sleep(5);
 
-            TimeUnit.SECONDS.sleep(5);
 
-            LOGGER.info("当前缓存值={}", loadingCache.get(KEY));
+            LOGGER.info("当前缓存值={},缓存大小={}", loadingCache.get(KEY),loadingCache.size());
+            LOGGER.info("缓存的所有内容={}",loadingCache.asMap().toString());
             loadingCache.get(KEY).incrementAndGet();
 
-        } catch (ExecutionException |InterruptedException e ) {
+        } catch (ExecutionException e ) {
             LOGGER.error("Exception", e);
         }
     }
@@ -70,7 +76,7 @@ public static void main(String[] args) throws InterruptedException {
                     break;
                 }
                 //TimeUnit.SECONDS.sleep(5);
-                cacheLoaderTest.checkAlert();
+                cacheLoaderTest.checkAlert(integer);
                 LOGGER.info("job running times={}", integer);
             } catch (InterruptedException e) {
                 e.printStackTrace();
