We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents cf8ccec + 59bdcdf commit b1016c1Copy full SHA for b1016c1
src/main/java/com/rabbitmq/client/impl/ConsumerWorkService.java
@@ -27,7 +27,7 @@
27
28
final public class ConsumerWorkService {
29
private static final Logger LOGGER = LoggerFactory.getLogger(ConsumerWorkService.class);
30
- private static final int MAX_RUNNABLE_BLOCK_SIZE = 16;
+ private static final int MAX_RUNNABLE_BLOCK_SIZE = 256;
31
private static final int DEFAULT_NUM_THREADS = Math.max(1, Utils.availableProcessors());
32
private final ExecutorService executor;
33
private final boolean privateExecutor;
0 commit comments