fix(vertx): Use a worker pool for mining (#820)

MartinWitt · Jul 10, 2023 · 1026247 · 1026247
1 parent 3b3f843
commit 1026247
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 4 deletions.
diff --git a/github-bot/src/main/java/io/github/martinwitt/laughing_train/mining/QodanaPeriodicMiner.java b/github-bot/src/main/java/io/github/martinwitt/laughing_train/mining/QodanaPeriodicMiner.java
@@ -80,7 +80,9 @@ private Project getKnownProject() {
     void mine(@Observes StartupEvent event) {
         try {
             logger.atInfo().log("Starting Qodana periodic miner");
-            vertx.setTimer(TimeUnit.MINUTES.toMillis(5), v -> vertx.executeBlocking(it -> mineRandomRepo()));
+            vertx.exceptionHandler(it -> logger.atWarning().withCause(it).log("Exception in vertx"));
+            vertx.setTimer(TimeUnit.MINUTES.toMillis(3), v -> vertx.createSharedWorkerExecutor("MINING", 5, 30L)
+                    .executeBlocking(it -> mineRandomRepo()));
         } catch (Exception e) {
             logger.atWarning().withCause(e).log("Failed to repo with Qodana");
         }
@@ -124,7 +126,8 @@ private void mineRandomRepo() {
         } finally {
             logger.atInfo().log("Queue size: %s", queue.size());
             logger.atInfo().log("Mining next repo in 1 minute");
-            vertx.setTimer(TimeUnit.MINUTES.toMillis(1), v -> vertx.executeBlocking(it -> mineRandomRepo()));
+            vertx.setTimer(TimeUnit.MINUTES.toMillis(1), v -> vertx.createSharedWorkerExecutor("MINING", 5, 30L)
+                    .executeBlocking(it -> mineRandomRepo()));
         }
     }
 

diff --git a/github-bot/src/main/java/io/github/martinwitt/laughing_train/mining/SpoonPeriodicMiner.java b/github-bot/src/main/java/io/github/martinwitt/laughing_train/mining/SpoonPeriodicMiner.java
@@ -75,7 +75,9 @@ private Project getKnownProject() {
     void mine(@Observes StartupEvent event) {
         try {
             logger.atInfo().log("Start mining with spoon");
-            vertx.setTimer(TimeUnit.MINUTES.toMillis(5), v -> vertx.executeBlocking(it -> mineRandomRepo()));
+            vertx.exceptionHandler(it -> logger.atWarning().withCause(it).log("Exception in vertx"));
+            vertx.setTimer(TimeUnit.MINUTES.toMillis(3), v -> vertx.createSharedWorkerExecutor("MINING", 5, 30L)
+                    .executeBlocking(it -> mineRandomRepo()));
         } catch (Exception e) {
             logger.atWarning().withCause(e).log("Failed to repo with spoon");
         }
@@ -116,7 +118,8 @@ private void mineRandomRepo() {
         } finally {
             logger.atInfo().log("Queue size: %s", queue.size());
             logger.atInfo().log("Mining next repo in 1 minute");
-            vertx.setTimer(TimeUnit.MINUTES.toMillis(1), v -> vertx.executeBlocking(it -> mineRandomRepo()));
+            vertx.setTimer(TimeUnit.MINUTES.toMillis(1), v -> vertx.createSharedWorkerExecutor("MINING", 5, 30L)
+                    .executeBlocking(it -> mineRandomRepo()));
         }
     }