From 453682918b6b23720dace8547478fc250039e980 Mon Sep 17 00:00:00 2001 From: Albumen Kevin Date: Fri, 28 Jun 2024 19:21:02 +0800 Subject: [PATCH] Fix compile --- .../configcenter/file/FileSystemDynamicConfiguration.java | 5 +++-- .../file/FileSystemDynamicConfigurationTest.java | 4 ++-- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/dubbo-configcenter/dubbo-configcenter-file/src/main/java/org/apache/dubbo/common/config/configcenter/file/FileSystemDynamicConfiguration.java b/dubbo-configcenter/dubbo-configcenter-file/src/main/java/org/apache/dubbo/common/config/configcenter/file/FileSystemDynamicConfiguration.java index 575f677ca65..0c9223043e2 100644 --- a/dubbo-configcenter/dubbo-configcenter-file/src/main/java/org/apache/dubbo/common/config/configcenter/file/FileSystemDynamicConfiguration.java +++ b/dubbo-configcenter/dubbo-configcenter-file/src/main/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 executeMutually(final Object mutex, Callable callable) { diff --git a/dubbo-configcenter/dubbo-configcenter-file/src/test/java/org/apache/dubbo/common/config/configcenter/file/FileSystemDynamicConfigurationTest.java b/dubbo-configcenter/dubbo-configcenter-file/src/test/java/org/apache/dubbo/common/config/configcenter/file/FileSystemDynamicConfigurationTest.java index 7b4dfe86034..d0bed2a0149 100644 --- a/dubbo-configcenter/dubbo-configcenter-file/src/test/java/org/apache/dubbo/common/config/configcenter/file/FileSystemDynamicConfigurationTest.java +++ b/dubbo-configcenter/dubbo-configcenter-file/src/test/java/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());