natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Replace ArrayBlockingQuery by LinkedBlockingQueue in binary protocol RequestThreadPoolExecutor

This commit is contained in:
Sylvain Lebresne 2013-05-17 14:52:04 +02:00
parent 8b96334a0c
commit c22c685ffa
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java
View File

@ -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"));
}
}