fix test case

dromara · Feb 10, 2025 · 4d6925b · 4d6925b
1 parent 0625c53
commit 4d6925b
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 7 deletions.
diff --git a/...ter/src/test/java/org/dromara/dynamictp/test/configcenter/apollo/ApolloRefresherTest.java b/...ter/src/test/java/org/dromara/dynamictp/test/configcenter/apollo/ApolloRefresherTest.java
@@ -40,12 +40,12 @@ class ApolloRefresherTest extends DtpBaseTest {
     @Test
     void testRefresh() throws InterruptedException {
         int corePoolSize = context.getBean("dtpExecutor1", ThreadPoolExecutor.class).getCorePoolSize();
-        System.out.println(corePoolSize);
+        System.out.println("apollo refresher, corePoolSize before refresh: " + corePoolSize);
         Assertions.assertEquals(6, corePoolSize);
         mockConfigChange();
         Thread.sleep(6000L);
         corePoolSize = context.getBean("dtpExecutor1", ThreadPoolExecutor.class).getCorePoolSize();
-        System.out.println(corePoolSize);
+        System.out.println("apollo refresher, corePoolSize after refresh: " + corePoolSize);
         Assertions.assertEquals(10, corePoolSize);
     }
 

diff --git a/...enter/src/test/java/org/dromara/dynamictp/test/configcenter/cloud/CloudRefresherTest.java b/...enter/src/test/java/org/dromara/dynamictp/test/configcenter/cloud/CloudRefresherTest.java
@@ -39,13 +39,14 @@
 class CloudRefresherTest extends DtpBaseTest {
 
     @Test
-    void testCloudRefresh() {
+    void testCloudRefresh() throws InterruptedException {
         int corePoolSize = context.getBean("dtpExecutor1", ThreadPoolExecutor.class).getCorePoolSize();
-        System.out.println(corePoolSize);
+        System.out.println("corePoolSize before refresh: " + corePoolSize);
         Assertions.assertEquals(6, corePoolSize);
         mockEnvironmentChange();
+        Thread.sleep(2000L);
         corePoolSize = context.getBean("dtpExecutor1", ThreadPoolExecutor.class).getCorePoolSize();
-        System.out.println(corePoolSize);
+        System.out.println("corePoolSize after refresh: " + corePoolSize);
         Assertions.assertEquals(10, corePoolSize);
     }
 

diff --git a/...enter/src/test/java/org/dromara/dynamictp/test/configcenter/nacos/NacosRefresherTest.java b/...enter/src/test/java/org/dromara/dynamictp/test/configcenter/nacos/NacosRefresherTest.java
@@ -52,12 +52,12 @@ void testRefresh() throws InterruptedException {
         assert context.containsBean("dtpExecutor1") : "dtpExecutor1 bean not found!";
 
         int corePoolSize = context.getBean("dtpExecutor1", ThreadPoolExecutor.class).getCorePoolSize();
-        System.out.println(corePoolSize);
+        System.out.println("nacos refresher, corePoolSize before refresh: " + corePoolSize);
         Assertions.assertEquals(6, corePoolSize);
         mockConfigChange();
         Thread.sleep(2000L);
         corePoolSize = context.getBean("dtpExecutor1", ThreadPoolExecutor.class).getCorePoolSize();
-        System.out.println(corePoolSize);
+        System.out.println("nacos refresher, corePoolSize after refresh: " + corePoolSize);
         Assertions.assertEquals(10, corePoolSize);
     }