diff --git a/jeecg-module-auto-process/src/main/java/org/jeecg/modules/AutoProcessManager.java b/jeecg-module-auto-process/src/main/java/org/jeecg/modules/AutoProcessManager.java index 59496410..c237653e 100644 --- a/jeecg-module-auto-process/src/main/java/org/jeecg/modules/AutoProcessManager.java +++ b/jeecg-module-auto-process/src/main/java/org/jeecg/modules/AutoProcessManager.java @@ -93,6 +93,8 @@ public class AutoProcessManager{ throw new RuntimeException(e); } if(i==20 && actuator.isAlive()){ + //关闭线程内部资源,例如:线程池 + actuator.closeResource(); actuator.stop(); } if(!actuator.isAlive()){ diff --git a/jeecg-module-auto-process/src/main/java/org/jeecg/modules/EmailParsingActuator.java b/jeecg-module-auto-process/src/main/java/org/jeecg/modules/EmailParsingActuator.java index bf267392..90c1feef 100644 --- a/jeecg-module-auto-process/src/main/java/org/jeecg/modules/EmailParsingActuator.java +++ b/jeecg-module-auto-process/src/main/java/org/jeecg/modules/EmailParsingActuator.java @@ -19,6 +19,7 @@ import javax.mail.internet.MimeMessage; import java.util.ArrayList; import java.util.Date; import java.util.List; +import java.util.Objects; import java.util.concurrent.*; /** @@ -124,4 +125,13 @@ public class EmailParsingActuator extends Thread{ } } } + + /** + * 立即关闭线程池 + */ + protected void closeResource(){ + if(Objects.nonNull(poolExecutor)) { + poolExecutor.shutdownNow(); + } + } }