svn commit: r1159450 - in /incubator/hama/trunk: CHANGES.txt core/src/main/java/org/apache/hama/http/HttpServer.java

[ed...@apache.org]

Author: edwardyoon
Date: Thu Aug 18 23:54:17 2011
New Revision: 1159450

URL: http://svn.apache.org/viewvc?rev=1159450&view=rev
Log:
Update HttpServer to use QueuedThreadPool

Modified:
    incubator/hama/trunk/CHANGES.txt
    incubator/hama/trunk/core/src/main/java/org/apache/hama/http/HttpServer.java

Modified: incubator/hama/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/CHANGES.txt?rev=1159450&r1=1159449&r2=1159450&view=diff
==============================================================================
--- incubator/hama/trunk/CHANGES.txt (original)
+++ incubator/hama/trunk/CHANGES.txt Thu Aug 18 23:54:17 2011
@@ -10,6 +10,7 @@ Release 0.4 - Unreleased
 
   IMPROVEMENTS
   
+    HAMA-422: Update HttpServer to use QueuedThreadPool (edwardyoon)
     HAMA-414: Move BSPPeer constructor into child process (edwardyoon)
     HAMA-419: Migrating site from forrest to maven (edwardyoon)
     

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/http/HttpServer.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/http/HttpServer.java?rev=1159450&r1=1159449&r2=1159450&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/http/HttpServer.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/http/HttpServer.java Thu Aug 18 23:54:17 2011
@@ -49,7 +49,7 @@ import org.mortbay.jetty.servlet.FilterM
 import org.mortbay.jetty.servlet.ServletHandler;
 import org.mortbay.jetty.servlet.ServletHolder;
 import org.mortbay.jetty.webapp.WebAppContext;
-import org.mortbay.thread.BoundedThreadPool;
+import org.mortbay.thread.QueuedThreadPool;
 import org.mortbay.util.MultiException;
 
 /**
@@ -98,7 +98,7 @@ public class HttpServer {
     listener.setPort(port);
     webServer.addConnector(listener);
 
-    webServer.setThreadPool(new BoundedThreadPool());
+    webServer.setThreadPool(new QueuedThreadPool());
 
     final String appDir = getWebAppsPath();
     ContextHandlerCollection contexts = new ContextHandlerCollection();
@@ -302,7 +302,7 @@ public class HttpServer {
    * Set the min, max number of worker threads (simultaneous connections).
    */
   public void setThreads(int min, int max) {
-    BoundedThreadPool pool = (BoundedThreadPool) webServer.getThreadPool();
+    QueuedThreadPool pool = (QueuedThreadPool) webServer.getThreadPool();
     pool.setMinThreads(min);
     pool.setMaxThreads(max);
   }