Fix compile

AlbumenJ · Jun 28, 2024 · 4536829 · 4536829
1 parent fbacaf1
commit 4536829
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/...java/org/apache/dubbo/common/config/configcenter/file/FileSystemDynamicConfiguration.java b/...java/org/apache/dubbo/common/config/configcenter/file/FileSystemDynamicConfiguration.java
@@ -53,6 +53,7 @@
 import java.util.Set;
 import java.util.TreeSet;
 import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.SynchronousQueue;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.atomic.AtomicBoolean;
@@ -552,8 +553,8 @@ protected static ThreadPoolExecutor getWatchEventsLoopThreadPool() {
         return WATCH_EVENTS_LOOP_THREAD_POOL;
     }
 
-    protected ThreadPoolExecutor getWorkersThreadPool() {
-        return (ThreadPoolExecutor) super.getWorkersThreadPool();
+    protected ExecutorService getWorkersThreadPool() {
+        return super.getWorkersThreadPool();
     }
 
     private <V> V executeMutually(final Object mutex, Callable<V> callable) {

diff --git a/.../org/apache/dubbo/common/config/configcenter/file/FileSystemDynamicConfigurationTest.java b/.../org/apache/dubbo/common/config/configcenter/file/FileSystemDynamicConfigurationTest.java
@@ -86,8 +86,8 @@ void testInit() {
         assertEquals("UTF-8", configuration.getEncoding());
         assertEquals(
                 ThreadPoolExecutor.class, configuration.getWorkersThreadPool().getClass());
-        assertEquals(1, (configuration.getWorkersThreadPool()).getCorePoolSize());
-        assertEquals(1, (configuration.getWorkersThreadPool()).getMaximumPoolSize());
+        assertEquals(1, ((ThreadPoolExecutor) configuration.getWorkersThreadPool()).getCorePoolSize());
+        assertEquals(1, ((ThreadPoolExecutor) configuration.getWorkersThreadPool()).getMaximumPoolSize());
 
         if (configuration.isBasedPoolingWatchService()) {
             assertEquals(2, configuration.getDelay());