优化代码

fengzhizi715 · Feb 21, 2021 · f088345 · f088345
1 parent 5c2faf4
commit f088345
Show file tree

Hide file tree

Showing 3 changed files with 42 additions and 12 deletions.
diff --git a/core/src/main/java/com/safframework/rxcache/domain/CacheStatistics.java b/core/src/main/java/com/safframework/rxcache/domain/CacheStatistics.java
@@ -27,13 +27,37 @@ public CacheStatistics(int size,int putCount,int evictionCount,int hitCount,int
 
     public int getSize() { return this.size; }
 
-    public int getPutCount() { return this.putCount; }
+    public int getPutCount() {
+        return putCount;
+    }
+
+    public void setPutCount(int putCount) {
+        this.putCount = putCount;
+    }
+
+    public int getEvictionCount() {
+        return evictionCount;
+    }
+
+    public void setEvictionCount(int evictionCount) {
+        this.evictionCount = evictionCount;
+    }
+
+    public int getHitCount() {
+        return hitCount;
+    }
 
-    public int getEvictionCount() { return this.evictionCount; }
+    public void setHitCount(int hitCount) {
+        this.hitCount = hitCount;
+    }
 
-    public int getHitCount() { return this.hitCount; }
+    public int getMissCount() {
+        return missCount;
+    }
 
-    public int getMissCount() { return this.missCount; }
+    public void setMissCount(int missCount) {
+        this.missCount = missCount;
+    }
 
     public void incrementPutCount() { this.putCount++; }
 

diff --git a/memory/caffeine/src/main/java/com/safframework/rxcache/memory/CaffeineImpl.java b/memory/caffeine/src/main/java/com/safframework/rxcache/memory/CaffeineImpl.java
@@ -27,6 +27,7 @@ public CaffeineImpl(long maxSize) {
                 .recordStats()
                 .maximumSize(maxSize)
                 .build();
+        this.cacheStatistics = new CacheStatistics((int)maxSize);
     }
 
     public CaffeineImpl(long maxSize, CacheConfig cacheConfig) {
@@ -50,6 +51,7 @@ public CaffeineImpl(long maxSize, CacheConfig cacheConfig) {
         }
 
         cache = caffeine.build();
+        this.cacheStatistics = new CacheStatistics((int)maxSize);
     }
 
     @Override
@@ -124,10 +126,11 @@ public CacheStatistics getCacheStatistics() {
 
         CacheStats cacheStats = cache.stats();
 
-        long evictionCount = cacheStats.evictionCount();
-        long hitCount = cacheStats.hitCount();
-        long missCount = cacheStats.missCount();
+        cacheStatistics.setPutCount(putCount.get());
+        cacheStatistics.setEvictionCount((int)cacheStats.evictionCount());
+        cacheStatistics.setHitCount((int)cacheStats.hitCount());
+        cacheStatistics.setMissCount((int)cacheStats.missCount());
 
-        return new CacheStatistics((int)maxSize,putCount.get(),(int)evictionCount,(int)hitCount,(int)missCount);
+        return cacheStatistics;
     }
 }
diff --git a/memory/guava-cache/src/main/java/com/safframework/rxcache/memory/GuavaCacheImpl.java b/memory/guava-cache/src/main/java/com/safframework/rxcache/memory/GuavaCacheImpl.java
@@ -34,6 +34,7 @@ public String load(String key) throws Exception {
                         return key;
                     }
                 });
+        this.cacheStatistics = new CacheStatistics((int)maxSize);
     }
 
     public GuavaCacheImpl(long maxSize, CacheConfig cacheConfig) {
@@ -63,6 +64,7 @@ public String load(String key) throws Exception {
                         return key;
                     }
                 });
+        this.cacheStatistics = new CacheStatistics((int)maxSize);
     }
 
     @Override
@@ -137,10 +139,11 @@ public CacheStatistics getCacheStatistics() {
 
         CacheStats cacheStats = cache.stats();
 
-        long evictionCount = cacheStats.evictionCount();
-        long hitCount = cacheStats.hitCount();
-        long missCount = cacheStats.missCount();
+        cacheStatistics.setPutCount(putCount.get());
+        cacheStatistics.setEvictionCount((int)cacheStats.evictionCount());
+        cacheStatistics.setHitCount((int)cacheStats.hitCount());
+        cacheStatistics.setMissCount((int)cacheStats.missCount());
 
-        return new CacheStatistics((int)maxSize,putCount.get(),(int)evictionCount,(int)hitCount,(int)missCount);
+        return cacheStatistics;
     }
 }