添加ExectorServiceUtils

Author: saleson

spring-cloud-gray-utils/src/main/java/cn/springcloud/gray/concurrent/ConcurrnetProperties.java

@@ -0,0 +1,22 @@
+package cn.springcloud.gray.concurrent;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @author saleson
+ * @date 2020-09-23 23:39
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class ConcurrnetProperties {
+    private int corePoolSize = 5;
+    private int maximumPoolSize = 20;
+    private long keepAliveTime = 30000;
+    private int queueSize = 10;
+    private String threadPrefix;
+}

spring-cloud-gray-utils/src/main/java/cn/springcloud/gray/concurrent/ExectorServiceUtils.java

@@ -0,0 +1,35 @@
+package cn.springcloud.gray.concurrent;
+
+import cn.springcloud.gray.utils.StringUtils;
+
+import java.util.concurrent.*;
+
+/**
+ * @author saleson
+ * @date 2020-09-23 23:43
+ */
+public class ExectorServiceUtils {
+
+    public static ExecutorService createExecutorService(ConcurrnetProperties concurrnetProperties) {
+        BlockingQueue<Runnable> workQueue = null;
+        if (concurrnetProperties.getQueueSize() == 0) {
+            workQueue = new SynchronousQueue<>();
+        } else if (concurrnetProperties.getQueueSize() < 0) {
+            workQueue = new LinkedBlockingQueue<>();
+        } else {
+            workQueue = new ArrayBlockingQueue<>(concurrnetProperties.getQueueSize());
+        }
+
+        ThreadFactory threadFactory = StringUtils.isEmpty(concurrnetProperties.getThreadPrefix()) ?
+                Executors.defaultThreadFactory() : new DefaultThreadFactory(concurrnetProperties.getThreadPrefix());
+
+        return new ThreadPoolExecutor(
+                concurrnetProperties.getCorePoolSize(),
+                concurrnetProperties.getMaximumPoolSize(),
+                concurrnetProperties.getKeepAliveTime(),
+                TimeUnit.MILLISECONDS,
+                workQueue,
+                threadFactory
+        );
+    }
+}