diff --git a/config/nacos/application-common.yml b/config/nacos/application-common.yml index 2a2b93cd..f3d41f54 100644 --- a/config/nacos/application-common.yml +++ b/config/nacos/application-common.yml @@ -26,6 +26,8 @@ dubbo: port: -1 # 指定dubbo协议注册ip # host: 192.168.0.100 + # 开启虚拟线程 + # threadpool: virtual # 消费者相关配置 consumer: # 超时时间 diff --git a/ruoyi-common/ruoyi-common-dubbo/src/main/java/org/dromara/common/dubbo/threadpool/VirtualOrCachedThreadPool.java b/ruoyi-common/ruoyi-common-dubbo/src/main/java/org/dromara/common/dubbo/threadpool/VirtualOrCachedThreadPool.java deleted file mode 100644 index c57f8b9f..00000000 --- a/ruoyi-common/ruoyi-common-dubbo/src/main/java/org/dromara/common/dubbo/threadpool/VirtualOrCachedThreadPool.java +++ /dev/null @@ -1,23 +0,0 @@ -package org.dromara.common.dubbo.threadpool; - -import org.apache.dubbo.common.URL; -import org.apache.dubbo.common.threadpool.ThreadPool; -import org.apache.dubbo.common.threadpool.support.cached.CachedThreadPool; -import org.apache.dubbo.common.threadpool.support.loom.VirtualThreadPool; -import org.dromara.common.core.utils.SpringUtils; - -import java.util.concurrent.Executor; - -/** - * 自定义dubbo线程池配置兼容jdk17与jdk21 - */ -public class VirtualOrCachedThreadPool implements ThreadPool { - @Override - public Executor getExecutor(URL url) { - if (SpringUtils.isVirtual()) { - // 如果开启了虚拟线程 使用虚拟线程池 - return new VirtualThreadPool().getExecutor(url); - } - return new CachedThreadPool().getExecutor(url); - } -} diff --git a/ruoyi-common/ruoyi-common-dubbo/src/main/resources/META-INF/dubbo/org.apache.dubbo.common.threadpool.ThreadPool b/ruoyi-common/ruoyi-common-dubbo/src/main/resources/META-INF/dubbo/org.apache.dubbo.common.threadpool.ThreadPool deleted file mode 100644 index d9bf4f51..00000000 --- a/ruoyi-common/ruoyi-common-dubbo/src/main/resources/META-INF/dubbo/org.apache.dubbo.common.threadpool.ThreadPool +++ /dev/null @@ -1,2 +0,0 @@ -virtualOrCached=org.dromara.common.dubbo.threadpool.VirtualOrCachedThreadPool -