You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ozone.apache.org by so...@apache.org on 2022/10/04 09:34:15 UTC
[ozone] branch master updated: HDDS-7283. Set coreSize equal to maxSize for threadPoolExecutor (#3792)
This is an automated email from the ASF dual-hosted git repository.
sodonnell pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new d029910e75 HDDS-7283. Set coreSize equal to maxSize for threadPoolExecutor (#3792)
d029910e75 is described below
commit d029910e758812e3c15be9a3ba371d37443ead39
Author: Symious <yi...@foxmail.com>
AuthorDate: Tue Oct 4 17:34:08 2022 +0800
HDDS-7283. Set coreSize equal to maxSize for threadPoolExecutor (#3792)
---
.../commandhandler/DeleteBlocksCommandHandler.java | 11 ++++-------
.../commandhandler/DeleteContainerCommandHandler.java | 11 ++++-------
2 files changed, 8 insertions(+), 14 deletions(-)
diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/DeleteBlocksCommandHandler.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/DeleteBlocksCommandHandler.java
index 8e95017aaf..835b060091 100644
--- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/DeleteBlocksCommandHandler.java
+++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/DeleteBlocksCommandHandler.java
@@ -60,9 +60,9 @@ import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.function.Consumer;
@@ -92,12 +92,9 @@ public class DeleteBlocksCommandHandler implements CommandHandler {
ConfigurationSource conf, int threadPoolSize, int queueLimit) {
this.containerSet = cset;
this.conf = conf;
- this.executor = new ThreadPoolExecutor(
- 0, threadPoolSize, 60, TimeUnit.SECONDS,
- new LinkedBlockingQueue<>(),
- new ThreadFactoryBuilder().setDaemon(true)
- .setNameFormat("DeleteBlocksCommandHandlerThread-%d")
- .build());
+ this.executor = Executors.newFixedThreadPool(
+ threadPoolSize, new ThreadFactoryBuilder()
+ .setNameFormat("DeleteBlocksCommandHandlerThread-%d").build());
this.deleteCommandQueues = new LinkedBlockingQueue<>(queueLimit);
handlerThread = new Daemon(new DeleteCmdWorker());
handlerThread.start();
diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/DeleteContainerCommandHandler.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/DeleteContainerCommandHandler.java
index 8290afc77d..58ad2d18e4 100644
--- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/DeleteContainerCommandHandler.java
+++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/DeleteContainerCommandHandler.java
@@ -33,7 +33,7 @@ import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.util.concurrent.ExecutorService;
-import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
@@ -52,12 +52,9 @@ public class DeleteContainerCommandHandler implements CommandHandler {
private final ExecutorService executor;
public DeleteContainerCommandHandler(int threadPoolSize) {
- this.executor = new ThreadPoolExecutor(
- 0, threadPoolSize, 60, TimeUnit.SECONDS,
- new LinkedBlockingQueue<>(),
- new ThreadFactoryBuilder().setDaemon(true)
- .setNameFormat("DeleteContainerThread-%d")
- .build());
+ this.executor = Executors.newFixedThreadPool(
+ threadPoolSize, new ThreadFactoryBuilder()
+ .setNameFormat("DeleteContainerThread-%d").build());
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@ozone.apache.org
For additional commands, e-mail: commits-help@ozone.apache.org