Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

403591 do not use the ConcurrentArrayBlockingQueue for thread pool, selector and async request log

This commit is contained in:
Greg Wilkins 2013-04-11 11:45:53 +10:00
parent c7c3e4455f
commit 4c04f5dd40
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
jetty-server/src/main/java/org/eclipse/jetty/server/AsyncNCSARequestLog.java
View File

@ -57,7 +57,7 @@ public class AsyncNCSARequestLog extends NCSARequestLog
{ {
super(filename); super(filename);
if (queue==null) if (queue==null)
queue=new ConcurrentArrayBlockingQueue.Bounded<String>(1024); queue=new ConcurrentArrayBlockingQueue.Unbounded<String>();
_queue=queue; _queue=queue;
} }

4
jetty-util/src/main/java/org/eclipse/jetty/util/thread/QueuedThreadPool.java
View File

@ -31,6 +31,7 @@ import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicLong;
import org.eclipse.jetty.util.BlockingArrayQueue; import org.eclipse.jetty.util.BlockingArrayQueue;
import org.eclipse.jetty.util.ConcurrentArrayBlockingQueue;
import org.eclipse.jetty.util.StringUtil; import org.eclipse.jetty.util.StringUtil;
import org.eclipse.jetty.util.annotation.ManagedAttribute; import org.eclipse.jetty.util.annotation.ManagedAttribute;
import org.eclipse.jetty.util.annotation.ManagedObject; import org.eclipse.jetty.util.annotation.ManagedObject;
@ -91,7 +92,8 @@ public class QueuedThreadPool extends AbstractLifeCycle implements SizedThreadPo
setStopTimeout(5000); setStopTimeout(5000);
if (queue==null) if (queue==null)
queue=new BlockingArrayQueue<Runnable>(_minThreads, _minThreads);// TODO ConcurrentArrayBlockingQueue.Unbounded<Runnable>(); queue=new ConcurrentArrayBlockingQueue.Unbounded<Runnable>();
// queue=new BlockingArrayQueue<Runnable>(_minThreads, _minThreads);
_jobs=queue; _jobs=queue;
} }