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) {