Modified: tomcat/trunk/java/org/apache/catalina/tribes/util/ExecutorFactory.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/util/ExecutorFactory.java?rev=978840&r1=978839&r2=978840&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/catalina/tribes/util/ExecutorFactory.java (original) +++ tomcat/trunk/java/org/apache/catalina/tribes/util/ExecutorFactory.java Sat Jul 24 10:17:45 2010 @@ -27,21 +27,21 @@ import java.util.concurrent.TimeUnit; public class ExecutorFactory { - public static ExecutorService newThreadPool(int minThreads, int maxThreads, long maxIdleTime, TimeUnit unit) { - TaskQueue taskqueue = new TaskQueue(); - ThreadPoolExecutor service = new ThreadPoolExecutor(minThreads, maxThreads, maxIdleTime, unit,taskqueue); - taskqueue.setParent(service); - return service; - } - - public static ExecutorService newThreadPool(int minThreads, int maxThreads, long maxIdleTime, TimeUnit unit, ThreadFactory threadFactory) { - TaskQueue taskqueue = new TaskQueue(); - ThreadPoolExecutor service = new ThreadPoolExecutor(minThreads, maxThreads, maxIdleTime, unit,taskqueue, threadFactory); - taskqueue.setParent(service); - return service; - } - - // ---------------------------------------------- TaskQueue Inner Class + public static ExecutorService newThreadPool(int minThreads, int maxThreads, long maxIdleTime, TimeUnit unit) { + TaskQueue taskqueue = new TaskQueue(); + ThreadPoolExecutor service = new ThreadPoolExecutor(minThreads, maxThreads, maxIdleTime, unit,taskqueue); + taskqueue.setParent(service); + return service; + } + + public static ExecutorService newThreadPool(int minThreads, int maxThreads, long maxIdleTime, TimeUnit unit, ThreadFactory threadFactory) { + TaskQueue taskqueue = new TaskQueue(); + ThreadPoolExecutor service = new ThreadPoolExecutor(minThreads, maxThreads, maxIdleTime, unit,taskqueue, threadFactory); + taskqueue.setParent(service); + return service; + } + + // ---------------------------------------------- TaskQueue Inner Class private static class TaskQueue extends LinkedBlockingQueue<Runnable> { ThreadPoolExecutor parent = null;
--------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org For additional commands, e-mail: dev-h...@tomcat.apache.org