Bump jboss-threads version to 3.8.0.Final a disable queue size tracki…

…ng42
franz1981 · Oct 2, 2024 · 5f2ff0f · 5f2ff0f
1 parent 1365271
commit 5f2ff0f
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 1 deletion.
diff --git a/bom/application/pom.xml b/bom/application/pom.xml
@@ -113,7 +113,7 @@
         <wildfly-client-config.version>1.0.1.Final</wildfly-client-config.version>
         <wildfly-elytron.version>2.6.0.Final</wildfly-elytron.version>
         <jboss-marshalling.version>2.2.1.Final</jboss-marshalling.version>
-        <jboss-threads.version>3.6.1.Final</jboss-threads.version>
+        <jboss-threads.version>3.8.0.Final</jboss-threads.version>
         <vertx.version>4.5.10</vertx.version>
         <httpclient.version>4.5.14</httpclient.version>
         <httpcore.version>4.4.16</httpcore.version>

diff --git a/core/builder/src/main/java/io/quarkus/builder/Execution.java b/core/builder/src/main/java/io/quarkus/builder/Execution.java
@@ -56,6 +56,7 @@ final class Execution {
         this.finalIds = finalIds;
         final EnhancedQueueExecutor.Builder executorBuilder = new EnhancedQueueExecutor.Builder();
         executorBuilder.setRegisterMBean(false);
+        executorBuilder.setQueueLimited(false);
         executorBuilder.setCorePoolSize(8).setMaximumPoolSize(1024);
         executorBuilder.setExceptionHandler(JBossExecutors.loggingExceptionHandler());
         executorBuilder.setThreadFactory(new JBossThreadFactory(new ThreadGroup("build group"), Boolean.FALSE, null, "build-%t",

diff --git a/core/runtime/src/main/java/io/quarkus/runtime/ExecutorRecorder.java b/core/runtime/src/main/java/io/quarkus/runtime/ExecutorRecorder.java
@@ -170,9 +170,12 @@ private static EnhancedQueueExecutor createExecutor(ThreadPoolConfig threadPoolC
         if (threadPoolConfig.queueSize.isPresent()) {
             if (threadPoolConfig.queueSize.getAsInt() < 0) {
                 builder.setMaximumQueueSize(Integer.MAX_VALUE);
+                builder.setQueueLimited(false);
             } else {
                 builder.setMaximumQueueSize(threadPoolConfig.queueSize.getAsInt());
             }
+        } else {
+            builder.setQueueLimited(false);
         }
         builder.setGrowthResistance(threadPoolConfig.growthResistance);
         builder.setKeepAliveTime(threadPoolConfig.keepAliveTime);

diff --git a/...ons/vertx/runtime/src/main/java/io/quarkus/vertx/core/runtime/QuarkusExecutorFactory.java b/...ons/vertx/runtime/src/main/java/io/quarkus/vertx/core/runtime/QuarkusExecutorFactory.java
@@ -88,9 +88,12 @@ private ExecutorService internalCreateExecutor(ThreadFactory threadFactory, Inte
             if (conf.queueSize().isPresent()) {
                 if (conf.queueSize().getAsInt() < 0) {
                     builder.setMaximumQueueSize(Integer.MAX_VALUE);
+                    builder.setQueueLimited(false);
                 } else {
                     builder.setMaximumQueueSize(conf.queueSize().getAsInt());
                 }
+            } else {
+                builder.setQueueLimited(false);
             }
             builder.setGrowthResistance(conf.growthResistance());
             builder.setKeepAliveTime(conf.keepAliveTime());