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 13:50:12 UTC
svn commit: r1357567 -
/accumulo/trunk/core/src/main/java/org/apache/accumulo/core/util/SimpleThreadPool.java
Author: ecn
Date: Thu Jul 5 11:50:12 2012
New Revision: 1357567
URL: http://svn.apache.org/viewvc?rev=1357567&view=rev
Log:
ACCUMULO-669 use the max number of threads argument
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=1357567&r1=1357566&r2=1357567&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 11:50:12 2012
@@ -22,12 +22,12 @@ import java.util.concurrent.TimeUnit;
/**
- *
+ * Create a simple thread pool using common parameters.
*/
public class SimpleThreadPool extends ThreadPoolExecutor {
public SimpleThreadPool(int max, final String name) {
- super(0, Integer.MAX_VALUE, 1l, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), new NamingThreadFactory(name));
+ super(0, max, 1l, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), new NamingThreadFactory(name));
}
}