From 5acb8f82e79c59702cdd112cdb13ebbc5a55e4a4 Mon Sep 17 00:00:00 2001
From: tjq <tengjiqi@gmail.com>
Date: Mon, 12 Sep 2022 22:59:00 +0800
Subject: [PATCH] feat: optimize OmsLocalDbPool config

---
 .../java/tech/powerjob/server/config/ThreadPoolConfig.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/config/ThreadPoolConfig.java b/powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/config/ThreadPoolConfig.java
index 99b61ade..899c182e 100644
--- a/powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/config/ThreadPoolConfig.java
+++ b/powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/config/ThreadPoolConfig.java
@@ -53,8 +53,9 @@ public class ThreadPoolConfig {
     @Bean(PJThreadPool.LOCAL_DB_POOL)
     public TaskExecutor initOmsLocalDbPool() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-        executor.setCorePoolSize(Runtime.getRuntime().availableProcessors() / 2);
-        executor.setMaxPoolSize(Runtime.getRuntime().availableProcessors() / 2);
+        int tSize = Math.max(1, Runtime.getRuntime().availableProcessors() / 2);
+        executor.setCorePoolSize(tSize);
+        executor.setMaxPoolSize(tSize);
         executor.setQueueCapacity(2048);
         executor.setThreadNamePrefix("PJ-LOCALDB-");
         executor.setRejectedExecutionHandler(RejectedExecutionHandlerFactory.newAbort(PJThreadPool.LOCAL_DB_POOL));