Dear Wiki user, You have subscribed to a wiki page or wiki category on "Cassandra Wiki" for change notification.
The "JmxInterface" page has been changed by RobertColi. http://wiki.apache.org/cassandra/JmxInterface?action=diff&rev1=12&rev2=13 -------------------------------------------------- private static int consistencyThreads_ = 4; // not configurable }}} + The CONSISTENCY-MANAGER executor is responsible for passive read repair, for example after a read with ConsistencyLevel.ONE. + Per src/java/org/apache/cassandra/service/StorageService.java, {{{ /* This thread pool does consistency checks when the client doesn't care about consistency */ }}} - - The CONSISTENCY-MANAGER executor is responsible for passive read repair, for example after a read with ConsistencyLevel.ONE. <<Anchor(org.apache.cassandra.concurrent.FILEUTILS-DELETE-POOL)>> == org.apache.cassandra.concurrent.FILEUTILS-DELETE-POOL == @@ -81, +81 @@ <<Anchor(org.apache.cassandra.concurrent.FLUSH-SORTER-POOL)>> == org.apache.cassandra.concurrent.FLUSH-SORTER-POOL == + This thread pool is multi-threaded, with between 1 and Runtime.getRuntime().availableProcessors() threads in the pool. + See Also : [[#org.apache.cassandra.concurrent.FLUSH-WRITER-POOL|FLUSH-WRITER-POOL]] and [[#org.apache.cassandra.concurrent.MEMTABLE-POST-FLUSHER|MEMTABLE-POST-FLUSHER]]. Per src/java/org/apache/cassandra/db/ColumnFamilyStore.java, {{{ * submitFlush first puts [Binary]Memtable.getSortedContents on the flushSorter executor, @@ -100, +102 @@ <<Anchor(org.apache.cassandra.concurrent.FLUSH-WRITER-POOL)>> == org.apache.cassandra.concurrent.FLUSH-WRITER-POOL == + This thread pool is multi-threaded, with between 1 and Runtime.getRuntime().availableProcessors() threads in the pool. + See Also : [[#org.apache.cassandra.concurrent.FLUSH-SORTER-POOL|FLUSH-SORTER-POOL]] and [[#org.apache.cassandra.concurrent.MEMTABLE-POST-FLUSHER|MEMTABLE-POST-FLUSHER]]. Per src/java/org/apache/cassandra/db/ColumnFamilyStore.java, {{{ * submitFlush first puts [Binary]Memtable.getSortedContents on the flushSorter executor, @@ -180, +184 @@ }}} <<Anchor(org.apache.cassandra.concurrent.MESSAGE-DESERIALIZER-POOL)>> == org.apache.cassandra.concurrent.MESSAGE-DESERIALIZER-POOL == + This thread pool is multi-threaded, with between 1 and Runtime.getRuntime().availableProcessors() threads in the pool. + Per src/java/org/apache/cassandra/net/MessagingService.java, {{{ // read executor puts messages to deserialize on this. @@ -193, +199 @@ <<Anchor(org.apache.cassandra.concurrent.RESPONSE-STAGE)>> == org.apache.cassandra.concurrent.RESPONSE-STAGE == - This stage is multi-threaded. + This thread pool is mutli-threaded and has between 1 and Runtime.getRuntime().availableProcessors() threads in the pool. <<Anchor(org.apache.cassandra.concurrent.ROW-MUTATION-STAGE)>> == org.apache.cassandra.concurrent.ROW-MUTATION-STAGE == - This stage is multi-threaded. + This thread pool is multi-threaded and has between 1 and concurrectWriters threads in the pool. + + Per src/java/org/apache/cassandra/concurrent/StageManager.java, + {{{ + private static int concurrentWriters_ = 32; + }}} <<Anchor(org.apache.cassandra.concurrent.ROW-READ-STAGE)>> == org.apache.cassandra.concurrent.ROW-READ-STAGE == - This stage is multi-threaded. + This thread pool is multi-threaded and has between 1 and concurrectReaders threads in the pool. + + Per src/java/org/apache/cassandra/concurrent/StageManager.java, + {{{ + private static int concurrentReaders_ = 8; + }}} <<Anchor(org.apache.cassandra.concurrent.STREAM-STAGE)>> == org.apache.cassandra.concurrent.STREAM-STAGE ==
