You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2012/07/05 14:29:04 UTC
svn commit: r1357579 -
/accumulo/trunk/core/src/main/java/org/apache/accumulo/core/util/SimpleThreadPool.java
Author: ecn
Date: Thu Jul 5 12:29:04 2012
New Revision: 1357579
URL: http://svn.apache.org/viewvc?rev=1357579&view=rev
Log:
ACCUMULO-669 fix calls to ThreadPoolExecutor to work the way I think it should work
Modified:
accumulo/trunk/core/src/main/java/org/apache/accumulo/core/util/SimpleThreadPool.java
Modified: accumulo/trunk/core/src/main/java/org/apache/accumulo/core/util/SimpleThreadPool.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/core/src/main/java/org/apache/accumulo/core/util/SimpleThreadPool.java?rev=1357579&r1=1357578&r2=1357579&view=diff
==============================================================================
--- accumulo/trunk/core/src/main/java/org/apache/accumulo/core/util/SimpleThreadPool.java (original)
+++ accumulo/trunk/core/src/main/java/org/apache/accumulo/core/util/SimpleThreadPool.java Thu Jul 5 12:29:04 2012
@@ -27,7 +27,8 @@ import java.util.concurrent.TimeUnit;
public class SimpleThreadPool extends ThreadPoolExecutor {
public SimpleThreadPool(int max, final String name) {
- super(0, max, 1l, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), new NamingThreadFactory(name));
+ super(max, max, 1l, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), new NamingThreadFactory(name));
+ allowCoreThreadTimeOut(true);
}
}