Skip to content

Commit 7f06377

Browse files
Merge pull request #29 from rabbitmq/bug26617
Use 2 * number of cores for ConsumerWorkService by default
2 parents 98245d1 + c2e17f4 commit 7f06377

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/com/rabbitmq/client/impl/ConsumerWorkService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525

2626
final public class ConsumerWorkService {
2727
private static final int MAX_RUNNABLE_BLOCK_SIZE = 16;
28-
private static final int DEFAULT_NUM_THREADS = 5;
28+
private static final int DEFAULT_NUM_THREADS = Runtime.getRuntime().availableProcessors() * 2;
2929
private final ExecutorService executor;
3030
private final boolean privateExecutor;
3131
private final WorkPool<Channel, Runnable> workPool;

0 commit comments

Comments
 (0)