From 2cb525bbf20a5a664adb86e49ea6a6903519f2c4 Mon Sep 17 00:00:00 2001 From: Greg Wilkins Date: Thu, 18 Jun 2009 01:14:49 +0000 Subject: [PATCH] nasty growth of job queue testing git-svn-id: svn+ssh://dev.eclipse.org/svnroot/rt/org.eclipse.jetty/jetty/trunk@420 7e9141cc-0065-0410-87d8-b60c137991c4 --- .../src/test/java/org/eclipse/jetty/server/StressTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/jetty-server/src/test/java/org/eclipse/jetty/server/StressTest.java b/jetty-server/src/test/java/org/eclipse/jetty/server/StressTest.java index 0195f65f558..3309f855ca2 100644 --- a/jetty-server/src/test/java/org/eclipse/jetty/server/StressTest.java +++ b/jetty-server/src/test/java/org/eclipse/jetty/server/StressTest.java @@ -34,6 +34,7 @@ import junit.framework.TestCase; import org.eclipse.jetty.server.bio.SocketConnector; import org.eclipse.jetty.server.handler.HandlerWrapper; import org.eclipse.jetty.server.nio.SelectChannelConnector; +import org.eclipse.jetty.util.BlockingArrayQueue; import org.eclipse.jetty.util.IO; import org.eclipse.jetty.util.log.Log; import org.eclipse.jetty.util.thread.QueuedThreadPool; @@ -48,7 +49,7 @@ public class StressTest extends TestCase protected InetAddress _addr; protected int _port; protected volatile AtomicInteger[] _loops; - protected QueuedThreadPool _threads=new QueuedThreadPool(); + protected QueuedThreadPool _threads=new QueuedThreadPool(new BlockingArrayQueue(4,4)); // protected ExecutorThreadPool _threads=new ExecutorThreadPool(100,500,10000,TimeUnit.MILLISECONDS); protected boolean _stress; private AtomicInteger _handled=new AtomicInteger(0);