Skip to content

Commit 020f36e

Browse files
committed
Use Virtual Threads for server startup
1 parent 9099f4b commit 020f36e

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

Diff for: core/trino-main/src/main/java/io/trino/server/ServerMainModule.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -168,6 +168,7 @@
168168
import static com.google.inject.multibindings.Multibinder.newSetBinder;
169169
import static com.google.inject.multibindings.OptionalBinder.newOptionalBinder;
170170
import static io.airlift.concurrent.Threads.daemonThreadsNamed;
171+
import static io.airlift.concurrent.Threads.virtualThreadsNamed;
171172
import static io.airlift.configuration.ConditionalModule.conditionalModule;
172173
import static io.airlift.configuration.ConfigBinder.configBinder;
173174
import static io.airlift.discovery.client.DiscoveryBinder.discoveryBinder;
@@ -183,6 +184,7 @@
183184
import static java.util.Objects.requireNonNull;
184185
import static java.util.concurrent.Executors.newCachedThreadPool;
185186
import static java.util.concurrent.Executors.newScheduledThreadPool;
187+
import static java.util.concurrent.Executors.newThreadPerTaskExecutor;
186188
import static java.util.concurrent.TimeUnit.SECONDS;
187189
import static org.weakref.jmx.guice.ExportBinder.newExporter;
188190

@@ -570,7 +572,7 @@ public static Executor createStartupExecutor(ServerConfig config)
570572
return directExecutor();
571573
}
572574
return new BoundedExecutor(
573-
newCachedThreadPool(daemonThreadsNamed("startup-%s")),
575+
newThreadPerTaskExecutor(virtualThreadsNamed("startup-%s")),
574576
Runtime.getRuntime().availableProcessors());
575577
}
576578

0 commit comments

Comments
 (0)