Author: david.lloyd(a)jboss.com Date: 2010-03-04 00:52:01 -0500 (Thu, 04 Mar 2010) New Revision: 5797 Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/stream/ObjectPipe.java Log: Use a deque Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/stream/ObjectPipe.java =================================================================== --- remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/stream/ObjectPipe.java 2010-03-04 04:57:00 UTC (rev 5796) +++ remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/stream/ObjectPipe.java 2010-03-04 05:52:01 UTC (rev 5797) @@ -25,11 +25,11 @@ import java.io.IOException; import java.io.InterruptedIOException; import java.io.EOFException; +import java.util.ArrayDeque; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.Condition; import java.util.Queue; -import java.util.LinkedList; import java.util.NoSuchElementException; /** @@ -46,7 +46,7 @@ // signal on read, await on write private final Condition readCondition = queueLock.newCondition(); - private final Queue<T> queue = new LinkedList<T>(); + private final Queue<T> queue; private final Source source = new Source(); private final Sink sink = new Sink(); @@ -60,6 +60,7 @@ */ public ObjectPipe(int max) { this.max = max; + queue = new ArrayDeque<T>(max); } /**