Skip to content

Commit 9ced5d4

Browse files
committed
Disable the use of virtual threads by default
1 parent e144f77 commit 9ced5d4

File tree

1 file changed

+8
-3
lines changed
  • src/main/java/com/rabbitmq/client/amqp/impl

1 file changed

+8
-3
lines changed

src/main/java/com/rabbitmq/client/amqp/impl/Utils.java

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -43,18 +43,23 @@
4343

4444
final class Utils {
4545

46+
private static final Logger LOGGER = LoggerFactory.getLogger(Utils.class);
47+
48+
static final boolean VIRTUAL_THREADS_ON =
49+
Boolean.parseBoolean(System.getProperty("rabbitmq.stream.threads.virtual.enabled", "false"));
50+
4651
static final int AVAILABLE_PROCESSORS = Runtime.getRuntime().availableProcessors();
4752

4853
static final Supplier<String> NAME_SUPPLIER = new NameSupplier("client.gen-");
4954

50-
private static final Logger LOGGER = LoggerFactory.getLogger(Utils.class);
51-
5255
private static final ThreadFactory THREAD_FACTORY;
5356
private static final Function<String, ExecutorService> EXECUTOR_SERVICE_FACTORY;
5457

5558
static {
59+
LOGGER.debug("Virtual threads enabled: {}", VIRTUAL_THREADS_ON);
60+
LOGGER.debug("Java 21 or more: {}", isJava21OrMore());
5661
if (isJava21OrMore()) {
57-
LOGGER.debug("Running Java 21 or more, using virtual threads");
62+
LOGGER.debug("Using virtual threads");
5863
Class<?> builderClass =
5964
Arrays.stream(Thread.class.getDeclaredClasses())
6065
.filter(c -> "Builder".equals(c.getSimpleName()))

0 commit comments

Comments
 (0)