⚡ graphAppInitializer: initialize apps on separate threads for faster…

… startup
SoftInstigate · Sep 26, 2024 · 75438cd · 75438cd
1 parent 94f3d20
commit 75438cd
Showing 1 changed file with 11 additions and 8 deletions.
diff --git a/graphql/src/main/java/org/restheart/graphql/initializers/GraphAppsInitializer.java b/graphql/src/main/java/org/restheart/graphql/initializers/GraphAppsInitializer.java
@@ -34,6 +34,7 @@
 import org.restheart.plugins.OnInit;
 import org.restheart.plugins.PluginsRegistry;
 import org.restheart.plugins.RegisterPlugin;
+import org.restheart.utils.ThreadsUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -90,14 +91,16 @@ public void init() {
                 .withDocumentClass(BsonDocument.class)
                 .find()
                 .forEach(appDef -> {
-                    try {
-                        var app = AppBuilder.build(appDef);
-                        var appUri = app.getDescriptor().getUri() != null ? app.getDescriptor().getUri() :  app.getDescriptor().getAppName();
-                        AppDefinitionLoadingCache.getCache().put(appUri, app);
-                        LOGGER.debug("GQL App Definition {} initialized", appUri);
-                    } catch (GraphQLIllegalAppDefinitionException e) {
-                        LOGGER.warn("GQL App Definition {} is invalid", appDef.get("_id"), e);
-                    }
+                    ThreadsUtils.virtualThreadsExecutor().execute(() -> {
+                        try {
+                            var app = AppBuilder.build(appDef);
+                            var appUri = app.getDescriptor().getUri() != null ? app.getDescriptor().getUri() :  app.getDescriptor().getAppName();
+                            AppDefinitionLoadingCache.getCache().put(appUri, app);
+                            LOGGER.debug("GQL App Definition {} initialized", appUri);
+                        } catch (GraphQLIllegalAppDefinitionException e) {
+                            LOGGER.warn("GQL App Definition {} is invalid", appDef.get("_id"), e);
+                        }
+                    });
                 });
         }
     }