fix:1.新加关闭主线程前先关闭内部线程池

This commit is contained in:
panbaolin 2024-02-23 21:55:31 +08:00
parent abe1d6dfb3
commit d5f7729976
2 changed files with 12 additions and 0 deletions

View File

@ -93,6 +93,8 @@ public class AutoProcessManager{
throw new RuntimeException(e); throw new RuntimeException(e);
} }
if(i==20 && actuator.isAlive()){ if(i==20 && actuator.isAlive()){
//关闭线程内部资源例如线程池
actuator.closeResource();
actuator.stop(); actuator.stop();
} }
if(!actuator.isAlive()){ if(!actuator.isAlive()){

View File

@ -19,6 +19,7 @@ import javax.mail.internet.MimeMessage;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Objects;
import java.util.concurrent.*; import java.util.concurrent.*;
/** /**
@ -124,4 +125,13 @@ public class EmailParsingActuator extends Thread{
} }
} }
} }
/**
* 立即关闭线程池
*/
protected void closeResource(){
if(Objects.nonNull(poolExecutor)) {
poolExecutor.shutdownNow();
}
}
} }