Backport CASSANDRA-13329: Use JMXEnabledThreadPoolExecutor with corePoolSize equal to maxPoolSize
Patch by Aleksandr Sorokoumov; reviewed by Alex Petrov for CASSANDRA-13329 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b337c690 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b337c690 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b337c690 Branch: refs/heads/cassandra-3.11 Commit: b337c690d321f2e4d7ebbbb0a1b8a90f986d21e9 Parents: 00a777e Author: Aleksandr Sorokoumov <aleksandr.sorokou...@gmail.com> Authored: Mon Apr 10 21:46:23 2017 +0200 Committer: Alex Petrov <oleksandr.pet...@gmail.com> Committed: Fri Jul 21 11:30:16 2017 +0200 ---------------------------------------------------------------------- CHANGES.txt | 1 + src/java/org/apache/cassandra/hints/HintsDispatchExecutor.java | 5 +---- 2 files changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/b337c690/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 9962f4b..efa57b3 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 3.0.15 + * JMXEnabledThreadPoolExecutor with corePoolSize equal to maxPoolSize (Backport CASSANDRA-13329) * Purge tombstones created by expired cells (CASSANDRA-13643) * Make concat work with iterators that have different subsets of columns (CASSANDRA-13482) * Set test.runners based on cores and memory size (CASSANDRA-13078) http://git-wip-us.apache.org/repos/asf/cassandra/blob/b337c690/src/java/org/apache/cassandra/hints/HintsDispatchExecutor.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/hints/HintsDispatchExecutor.java b/src/java/org/apache/cassandra/hints/HintsDispatchExecutor.java index 58b30bd..c9e69f5 100644 --- a/src/java/org/apache/cassandra/hints/HintsDispatchExecutor.java +++ b/src/java/org/apache/cassandra/hints/HintsDispatchExecutor.java @@ -56,10 +56,7 @@ final class HintsDispatchExecutor this.isPaused = isPaused; scheduledDispatches = new ConcurrentHashMap<>(); - executor = new JMXEnabledThreadPoolExecutor(1, - maxThreads, - 1, - TimeUnit.MINUTES, + executor = new JMXEnabledThreadPoolExecutor(maxThreads, 1, TimeUnit.MINUTES, new LinkedBlockingQueue<>(), new NamedThreadFactory("HintsDispatcher", Thread.MIN_PRIORITY), "internal"); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
