enhance

Signed-off-by: OneSizeFitQuorum <[email protected]>
apache · Sep 19, 2023 · 1c9abf3 · 1c9abf3
1 parent 05f3922
commit 1c9abf3
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerProxy.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerProxy.java
@@ -416,6 +416,12 @@ public void close() {
       LOG.warn(getId() + ": Failed to shutdown implExecutor", ignored);
     }
 
+    try {
+      ConcurrentUtils.shutdownAndWait(executor);
+    } catch (Exception ignored) {
+      LOG.warn(getId() + ": Failed to shutdown executor", ignored);
+    }
+
     lifeCycle.checkStateAndClose(() -> {
       LOG.info("{}: close", getId());
       impls.close();
@@ -431,12 +437,6 @@ public void close() {
       } catch (IOException ignored) {
         LOG.warn(getId() + ": Failed to close " + SupportedDataStreamType.NETTY + " server", ignored);
       }
-
-      try {
-        ConcurrentUtils.shutdownAndWait(executor);
-      } catch (Exception ignored) {
-        LOG.warn(getId() + ": Failed to shutdown executor", ignored);
-      }
     });
     pauseMonitor.stop();
   }