Netty服务端 线程池创建器编码

byit-plugin-core/byit-plugin-rpc-common/src/main/java/com/byit/utils/ThreadPoolUtil.java

+package com.byit.utils;
+
+import com.byit.rpc.util.RpcException;
+
+import java.util.concurrent.*;
+
+
+/**
+ * 线程池创建工具
+ * @author huangfu
+ */
+public class ThreadPoolUtil {
+
+    /**
+     * 线程池创建
+     * @param serverType 服务名称
+     * @return 返回一个线程池
+     */
+    public static ThreadPoolExecutor makeServerThreadPool(final String serverType, int corePoolSize, int maxPoolSize){
+        return  new ThreadPoolExecutor(
+                corePoolSize,
+                maxPoolSize,
+                60L,
+                TimeUnit.SECONDS,
+                new LinkedBlockingQueue<Runnable>(1000),
+                r -> new Thread(r, "myth-plugin-rpc, "+serverType+"-serverHandlerPool-" + r.hashCode()),
+                (r, executor) -> {
+                    throw new RpcException("myth-plugin-rpc "+serverType+" Thread pool is EXHAUSTED!");
+                });
+
+    }
+
+}