refactor: be more conservative w/preview features

Also test with virtual threads in we are using them in production.

1 files changed, 9 insertions, 0 deletions

diff --git a/subprojects/language-web/src/main/java/tools/refinery/language/web/ServerLauncher.java b/subprojects/language-web/src/main/java/tools/refinery/language/web/ServerLauncher.java
index 5da16850..960eef71 100644
--- a/subprojects/language-web/src/main/java/tools/refinery/language/web/ServerLauncher.java
+++ b/subprojects/language-web/src/main/java/tools/refinery/language/web/ServerLauncher.java
@@ -45,6 +45,7 @@ public class ServerLauncher {
 
         public ServerLauncher(InetSocketAddress bindAddress, String[] allowedOrigins, String webSocketUrl) {
                 server = new Server(bindAddress);
+                enableVirtualThreads(server);
                 if (server.getThreadPool() instanceof VirtualThreads.Configurable virtualThreadsConfigurable) {
                         // Change this to setVirtualThreadsExecutor once
                         // https://github.com/eclipse/jetty.project/commit/83154b4ffe4767ef44981598d6c26e6a5d32e57c gets released.
@@ -149,6 +150,14 @@ public class ServerLauncher {
                 }
         }
 
+        public static void enableVirtualThreads(Server server) {
+                if (server.getThreadPool() instanceof VirtualThreads.Configurable virtualThreadsConfigurable) {
+                        // Change this to setVirtualThreadsExecutor once
+                        // https://github.com/eclipse/jetty.project/commit/83154b4ffe4767ef44981598d6c26e6a5d32e57c gets released.
+                        virtualThreadsConfigurable.setUseVirtualThreads(VirtualThreads.areSupported());
+                }
+        }
+
         private static String getListenAddress() {
                 var listenAddress = System.getenv("LISTEN_ADDRESS");
                 if (listenAddress == null) {