(experiment) Also add clients to loom experiment

2025-10-06 07:32:38 +02:00 · 2025-07-16 18:08:00 +02:00
1 changed files with 3 additions and 2 deletions
--- a/code/common/service/java/nu/marginalia/service/client/GrpcChannelPoolFactory.java
+++ b/code/common/service/java/nu/marginalia/service/client/GrpcChannelPoolFactory.java
@@ -27,8 +27,9 @@ public class GrpcChannelPoolFactory {
    private static final Executor executor = useLoom
            ? Executors.newVirtualThreadPerTaskExecutor()
            : NamedExecutorFactory.createFixed("gRPC-Channel-Pool", Math.clamp(Runtime.getRuntime().availableProcessors() / 2, 2, 32));
-    private static final Executor offloadExecutor = NamedExecutorFactory.createFixed("gRPC-Offload-Pool",
-            Math.clamp(Runtime.getRuntime().availableProcessors() / 2, 2, 32));
+    private static final Executor offloadExecutor =  useLoom
+            ? Executors.newVirtualThreadPerTaskExecutor()
+            : NamedExecutorFactory.createFixed("gRPC-Offload-Pool", Math.clamp(Runtime.getRuntime().availableProcessors() / 2, 2, 32));

    @Inject
    public GrpcChannelPoolFactory(NodeConfigurationWatcher nodeConfigurationWatcher,