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 <[email protected]> Authored: Fri May 17 14:52:04 2013 +0200 Committer: Sylvain Lebresne <[email protected]> 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")); } }
