fix: runnableMap does not store complexQueryWorker threads

Author: LUAgam

src/main/java/com/actiontech/dble/DbleServer.java

@@ -303,7 +303,7 @@ private void initExecutor(int frontProcessorCount, int backendProcessorCount) {
         frontExecutor = ExecutorUtil.createFixed(FRONT_WORKER_NAME, SystemConfig.getInstance().getFrontWorker(), runnableMap);
         backendExecutor = ExecutorUtil.createFixed(BACKEND_WORKER_NAME, SystemConfig.getInstance().getBackendWorker(), runnableMap);
         writeToBackendExecutor = ExecutorUtil.createFixed(WRITE_TO_BACKEND_WORKER_NAME, SystemConfig.getInstance().getWriteToBackendWorker(), runnableMap);
-        complexQueryExecutor = ExecutorUtil.createCached(COMPLEX_QUERY_EXECUTOR_NAME, SystemConfig.getInstance().getComplexQueryWorker(), runnableMap);
+        complexQueryExecutor = ExecutorUtil.createCached(COMPLEX_QUERY_EXECUTOR_NAME, SystemConfig.getInstance().getComplexQueryWorker(), null);
         timerExecutor = ExecutorUtil.createFixed(TIMER_WORKER_NAME, 1);
         nioFrontExecutor = ExecutorUtil.createFixed(NIO_FRONT_RW, frontProcessorCount, runnableMap);
         nioBackendExecutor = ExecutorUtil.createFixed(NIO_BACKEND_RW, backendProcessorCount, runnableMap);

src/main/java/com/actiontech/dble/services/manager/information/tables/DbleThreadPool.java

@@ -123,15 +123,15 @@ public int updateRows(Set<LinkedHashMap<String, String>> affectPks, LinkedHashMa
             nameableExecutor.setCorePoolSize(corePoolSize);
             if (!nameableExecutor.getName().equals(DbleServer.COMPLEX_QUERY_EXECUTOR_NAME)) {
                 nameableExecutor.setMaximumPoolSize(corePoolSize);
-            }
-            if (oldSize < corePoolSize) {
-                try {
-                    increasePoolSize(nameableExecutor, corePoolSize - oldSize);
-                } catch (IOException e) {
-                    throw new SQLException(e.getMessage(), "42S22", ErrorCode.ER_YES);
+                if (oldSize < corePoolSize) {
+                    try {
+                        increasePoolSize(nameableExecutor, corePoolSize - oldSize);
+                    } catch (IOException e) {
+                        throw new SQLException(e.getMessage(), "42S22", ErrorCode.ER_YES);
+                    }
+                } else if (oldSize > corePoolSize) {
+                    decreasePoolSize(nameableExecutor, oldSize - corePoolSize);
                 }
-            } else if (oldSize > corePoolSize) {
-                decreasePoolSize(nameableExecutor, oldSize - corePoolSize);
             }
             //persistence
             try {