Merge pull request rabbitmq#29 from rabbitmq/bug26617

michaelklishin · michaelklishin · commit 7f0637753b89 · 2015-02-27T19:56:26.000+03:00
Use 2 * number of cores for ConsumerWorkService by default
diff --git a/src/com/rabbitmq/client/impl/ConsumerWorkService.java b/src/com/rabbitmq/client/impl/ConsumerWorkService.java
@@ -25,7 +25,7 @@
 
 final public class ConsumerWorkService {
     private static final int MAX_RUNNABLE_BLOCK_SIZE = 16;
-    private static final int DEFAULT_NUM_THREADS = 5;
+    private static final int DEFAULT_NUM_THREADS = Runtime.getRuntime().availableProcessors() * 2;
     private final ExecutorService executor;
     private final boolean privateExecutor;
     private final WorkPool<Channel, Runnable> workPool;
