cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yu...@apache.org
Subject [1/4] git commit: Replace ArrayBlockingQuery by LinkedBlockingQueue in binary protocol RequestThreadPoolExecutor
Date Fri, 17 May 2013 15:29:58 GMT
Updated Branches:
  refs/heads/cassandra-1.2 c22c685ff -> b69c1aa4c
  refs/heads/trunk 94d42a9b0 -> 8b410078a


Replace ArrayBlockingQuery by LinkedBlockingQueue in binary protocol RequestThreadPoolExecutor


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/c22c685f
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/c22c685f
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/c22c685f

Branch: refs/heads/trunk
Commit: c22c685ffa7da67b7ee069b37e7b3c770ee23263
Parents: 8b96334
Author: Sylvain Lebresne <sylvain@datastax.com>
Authored: Fri May 17 14:52:04 2013 +0200
Committer: Sylvain Lebresne <sylvain@datastax.com>
Committed: Fri May 17 14:52:04 2013 +0200

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


http://git-wip-us.apache.org/repos/asf/cassandra/blob/c22c685f/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java b/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java
index 83c7c29..faae28f 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"));
     }
 }


Mime
View raw message