[dubbo-samples] branch master updated: update CacheService for LRU2 (#292)

[albumenj]

This is an automated email from the ASF dual-hosted git repository.

albumenj pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-samples.git


The following commit(s) were added to refs/heads/master by this push:
     new 1265b01  update CacheService for LRU2 (#292)
1265b01 is described below

commit 1265b011cbcfe013e71f88ce5a820c677ae8e1bf
Author: gcx <18716558...@163.com>
AuthorDate: Thu Apr 1 10:31:15 2021 +0800

    update CacheService for LRU2 (#292)
---
 .../org/apache/dubbo/samples/cache/CacheConsumer.java   |  2 ++
 .../org/apache/dubbo/samples/cache/CacheServiceIT.java  | 17 ++++++++++++++---
 2 files changed, 16 insertions(+), 3 deletions(-)

diff --git 
a/dubbo-samples-cache/src/main/java/org/apache/dubbo/samples/cache/CacheConsumer.java
 
b/dubbo-samples-cache/src/main/java/org/apache/dubbo/samples/cache/CacheConsumer.java
index 3160f1a..c4b87c7 100644
--- 
a/dubbo-samples-cache/src/main/java/org/apache/dubbo/samples/cache/CacheConsumer.java
+++ 
b/dubbo-samples-cache/src/main/java/org/apache/dubbo/samples/cache/CacheConsumer.java
@@ -34,6 +34,7 @@ public class CacheConsumer {
         // verify cache, same result is returned for different invocations (in 
fact, the return value increases
         // on every invocation on the server side)
         String fix = null;
+        cacheService.findCache("0");
         for (int i = 0; i < 5; i++) {
             String result = cacheService.findCache("0");
             if (fix == null || fix.equals(result)) {
@@ -48,6 +49,7 @@ public class CacheConsumer {
         // default cache.size is 1000 for LRU, should have cache expired if 
invoke more than 1001 times
         for (int n = 0; n < 1001; n++) {
             String pre = null;
+            cacheService.findCache(String.valueOf(n));
             for (int i = 0; i < 10; i++) {
                 String result = cacheService.findCache(String.valueOf(n));
                 if (pre != null && !pre.equals(result)) {
diff --git 
a/dubbo-samples-cache/src/test/java/org/apache/dubbo/samples/cache/CacheServiceIT.java
 
b/dubbo-samples-cache/src/test/java/org/apache/dubbo/samples/cache/CacheServiceIT.java
index 0878689..55a8d9d 100644
--- 
a/dubbo-samples-cache/src/test/java/org/apache/dubbo/samples/cache/CacheServiceIT.java
+++ 
b/dubbo-samples-cache/src/test/java/org/apache/dubbo/samples/cache/CacheServiceIT.java
@@ -42,12 +42,23 @@ public class CacheServiceIT {
 
     @Test
     public void verifyLRU() throws Exception {
+        // this test is for LRU-2 cache only.
+        // verify cache, same result is returned for multiple invocations (in 
fact, the return value increases
+        // on every invocation on the server side)
         String value = service.findCache("0");
         for (int n = 0; n < 1001; n++) {
-            TestCase.assertEquals(service.findCache(String.valueOf(n)), 
service.findCache(String.valueOf(n)));
+            // default cache.size is 1000 for LRU, should have cache expired 
if invoke more than 1001 times
+            String pre = null;
+            service.findCache(String.valueOf(n));
+            for (int i = 0; i < 10; i++) {
+                String result = service.findCache(String.valueOf(n));
+                TestCase.assertTrue(pre == null || pre.equals(result));
+                pre = result;
+            }
         }
-        Assert.assertEquals(service.findCache("0"), service.findCache("0"));
-        Assert.assertNotEquals(value, service.findCache("0"));
+        // verify if the first cache item is expired in LRU cache
+        TestCase.assertFalse(value.equals(service.findCache("0")));
+        TestCase.assertEquals(service.findCache("0"), service.findCache("0"));
     }
 
 

---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@dubbo.apache.org
For additional commands, e-mail: notifications-h...@dubbo.apache.org