From 8f5df55ced5b2949d758a51b85f1529661986357 Mon Sep 17 00:00:00 2001 From: OneSizeFitQuorum Date: Wed, 24 Apr 2024 15:12:24 +0800 Subject: [PATCH] fix Signed-off-by: OneSizeFitQuorum --- .../iotdb/db/service/RegionMigrateService.java | 4 +--- .../commons/concurrent/IoTDBThreadPoolFactory.java | 12 ------------ 2 files changed, 1 insertion(+), 15 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/RegionMigrateService.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/RegionMigrateService.java index 5fea6c0a0088c..7061a6b5c380e 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/RegionMigrateService.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/RegionMigrateService.java @@ -222,9 +222,7 @@ private static class RegionMigratePool extends AbstractPoolManager { private final Logger poolLogger = LoggerFactory.getLogger(RegionMigratePool.class); private RegionMigratePool() { - this.pool = - IoTDBThreadPoolFactory.newCachedThreadPool( - ThreadName.REGION_MIGRATE.getName(), Runtime.getRuntime().availableProcessors() / 2); + this.pool = IoTDBThreadPoolFactory.newCachedThreadPool(ThreadName.REGION_MIGRATE.getName()); } @Override diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/concurrent/IoTDBThreadPoolFactory.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/concurrent/IoTDBThreadPoolFactory.java index 343711f0bab8b..1cf5488d91792 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/concurrent/IoTDBThreadPoolFactory.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/concurrent/IoTDBThreadPoolFactory.java @@ -178,18 +178,6 @@ public static ExecutorService newCachedThreadPool(String poolName) { poolName); } - public static ExecutorService newCachedThreadPool(String poolName, int maximumPoolSize) { - logger.info(NEW_CACHED_THREAD_POOL_LOGGER_FORMAT, poolName); - return new WrappedThreadPoolExecutor( - 0, - maximumPoolSize, - 60L, - TimeUnit.SECONDS, - new LinkedBlockingQueue<>(), - new IoTThreadFactory(poolName), - poolName); - } - public static ExecutorService newCachedThreadPool( String poolName, Thread.UncaughtExceptionHandler handler) { logger.info(NEW_CACHED_THREAD_POOL_LOGGER_FORMAT, poolName);