From f22e88f3277041c8335eec044134429c6c8e1afc Mon Sep 17 00:00:00 2001 From: lvxinran Date: Mon, 5 Jul 2021 11:08:54 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B0=9D=E8=AF=95=E4=BF=AE=E6=94=B9=E5=85=85?= =?UTF-8?q?=E5=80=BCbug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/ljsd/jieling/thread/ThreadManager.java | 3 +++ .../main/java/com/ljsd/jieling/thread/task/RPCServerTask.java | 2 ++ 2 files changed, 5 insertions(+) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/thread/ThreadManager.java b/serverlogic/src/main/java/com/ljsd/jieling/thread/ThreadManager.java index 9ac0f2560..918d5fe8c 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/thread/ThreadManager.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/thread/ThreadManager.java @@ -157,4 +157,7 @@ public class ThreadManager implements IManager { executor.execute(task); } + public static ThreadPoolExecutor getExecutor() { + return executor; + } } diff --git a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/RPCServerTask.java b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/RPCServerTask.java index 1670c0755..3e7a0d5cb 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/RPCServerTask.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/RPCServerTask.java @@ -4,6 +4,7 @@ import com.google.gson.Gson; import com.ljsd.CoreService; import com.ljsd.GameApplication; import com.ljsd.jieling.config.json.CoreSettings; +import com.ljsd.jieling.thread.ThreadManager; import com.ljsd.jieling.thrift.idl.RPCRequestIFace; import com.ljsd.jieling.util.ConfigurableApplicationContextManager; import org.apache.thrift.TProcessor; @@ -43,6 +44,7 @@ public class RPCServerTask extends Thread{ TBinaryProtocol.Factory proFactory = new TBinaryProtocol.Factory(true, true); trArgs.protocolFactory(proFactory); trArgs.maxWorkerThreads(16); + trArgs.executorService(ThreadManager.getExecutor()); LOGGER.info("run->RPC services is starting."); final TServer server = new TThreadPoolServer(trArgs); while (true) {