From c22c685ffa7da67b7ee069b37e7b3c770ee23263 Mon Sep 17 00:00:00 2001
From: Sylvain Lebresne <sylvain@datastax.com>
Date: Fri, 17 May 2013 14:52:04 +0200
Subject: [PATCH] Replace ArrayBlockingQuery by LinkedBlockingQueue in binary
 protocol RequestThreadPoolExecutor

---
 .../apache/cassandra/transport/RequestThreadPoolExecutor.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java b/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java
index 83c7c29661..faae28f7d6 100644
--- a/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java
+++ b/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java
@@ -17,7 +17,7 @@
  */
 package org.apache.cassandra.transport;
 
-import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
 
 import org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor;
@@ -33,7 +33,7 @@ public class RequestThreadPoolExecutor extends DebuggableThreadPoolExecutor
         super(DatabaseDescriptor.getNativeTransportMinThreads(),
               DatabaseDescriptor.getNativeTransportMaxThreads(),
               CORE_THREAD_TIMEOUT_SEC, TimeUnit.SECONDS,
-              new ArrayBlockingQueue(32), // Seems to help smooth latency compared to SynchronousQueue.
+              new LinkedBlockingQueue<Runnable>(32), // Seems to help smooth latency compared to SynchronousQueue.
               new NamedThreadFactory("Native-Transport-Requests"));
     }
 }