[jboss-remoting-commits] JBoss Remoting SVN: r5797 - remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/stream.

[jboss-remoting-commits at lists.jboss.org]

Author: david.lloyd at 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);
     }
 
     /**