Add isClosed in ShardingSphereProxy.

apache · Dec 13, 2024 · 21ad896 · 21ad896
1 parent f23d908
commit 21ad896
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/...tend/core/src/main/java/org/apache/shardingsphere/proxy/frontend/ShardingSphereProxy.java b/...tend/core/src/main/java/org/apache/shardingsphere/proxy/frontend/ShardingSphereProxy.java
@@ -54,6 +54,8 @@ public final class ShardingSphereProxy {
 
     private final EventLoopGroup workerGroup;
 
+    private boolean isClosed = false;
+
     public ShardingSphereProxy() {
         bossGroup = Epoll.isAvailable() ? new EpollEventLoopGroup(1) : new NioEventLoopGroup(1);
         workerGroup = getWorkerGroup();
@@ -157,10 +159,14 @@ private void initServerBootstrap(final ServerBootstrap bootstrap, final DomainSo
     /**
      * Close ShardingSphere-Proxy.
      */
-    public void close() {
+    public synchronized void close() {
+        if (isClosed) {
+            return;
+        }
         bossGroup.shutdownGracefully();
         workerGroup.shutdownGracefully();
         BackendExecutorContext.getInstance().getExecutorEngine().close();
         ProxyContext.getInstance().getContextManager().close();
+        isClosed = true;
     }
 }