You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ib...@apache.org on 2020/07/07 14:57:25 UTC
[accumulo] 09/09: re #1621: Simplified constructors in the
SimpleThreadPool
This is an automated email from the ASF dual-hosted git repository.
ibella pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/accumulo.git
commit 9c4f732e56f7d52f7969ad4a95904c51877ddc56
Author: Ivan Bella <iv...@bella.name>
AuthorDate: Tue Jul 7 09:08:46 2020 -0400
re #1621: Simplified constructors in the SimpleThreadPool
---
.../main/java/org/apache/accumulo/core/util/SimpleThreadPool.java | 6 +-----
1 file changed, 1 insertion(+), 5 deletions(-)
diff --git a/core/src/main/java/org/apache/accumulo/core/util/SimpleThreadPool.java b/core/src/main/java/org/apache/accumulo/core/util/SimpleThreadPool.java
index a052048..db2b415 100644
--- a/core/src/main/java/org/apache/accumulo/core/util/SimpleThreadPool.java
+++ b/core/src/main/java/org/apache/accumulo/core/util/SimpleThreadPool.java
@@ -36,11 +36,7 @@ public class SimpleThreadPool extends ThreadPoolExecutor {
}
public SimpleThreadPool(int coreAndMax, long threadTimeOut, final String name) {
- super(coreAndMax, coreAndMax, threadTimeOut, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(),
- new NamingThreadFactory(name));
- if (threadTimeOut > 0) {
- allowCoreThreadTimeOut(true);
- }
+ this(coreAndMax, threadTimeOut, name, new LinkedBlockingQueue<>());
}
public SimpleThreadPool(int coreAndMax, final String name, BlockingQueue<Runnable> queue) {