[ISSUE #3707]fix thread leak with rocketmq consumer start and shutdow…

…n frequently
apache · Apr 17, 2023 · e7081ca · e7081ca
1 parent 7a5746e
commit e7081ca
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java b/...main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
@@ -106,7 +106,9 @@ public void start() {
 
     @Override
     public void shutdown(long awaitTerminateMillis) {
-
+        this.scheduledExecutorService.shutdown();
+        org.apache.rocketmq.common.utils.ThreadUtils.shutdownGracefully(this.consumeExecutor, awaitTerminateMillis, TimeUnit.MILLISECONDS);
+        this.cleanExpireMsgExecutors.shutdown();
     }
 
     public void shutdown() {