svn commit: r1071482 - /cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/ColumnFamilyStore.java

[goffinet]

Author: goffinet
Date: Thu Feb 17 02:41:04 2011
New Revision: 1071482

URL: http://svn.apache.org/viewvc?rev=1071482&view=rev
Log:
Use a SynchronousQueue instead of LBQ so when memtable_flush_writers is > 1, it 
will allow actual parallel flushes. 
patch by goffinet reviewed by jbellis for CASSANDRA-2178


Modified:
    
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/ColumnFamilyStore.java

Modified: 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
URL: 
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/ColumnFamilyStore.java?rev=1071482&r1=1071481&r2=1071482&view=diff
==============================================================================
--- 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
 (original)
+++ 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
 Thu Feb 17 02:41:04 2011
@@ -88,7 +88,7 @@ public class ColumnFamilyStore implement
                                                
DatabaseDescriptor.getFlushWriters(),
                                                StageManager.KEEPALIVE,
                                                TimeUnit.SECONDS,
-                                               new 
LinkedBlockingQueue<Runnable>(DatabaseDescriptor.getFlushWriters()),
+                                               new 
SynchronousQueue<Runnable>(),
                                                new 
NamedThreadFactory("FlushWriter"),
                                                "internal");
     public static final ExecutorService postFlushExecutor = new 
JMXEnabledThreadPoolExecutor("MemtablePostFlusher");