change: 关闭逻辑调整.
This commit is contained in:
@@ -195,6 +195,7 @@ public final class SystemInitializer implements Refreshable, Clearable {
|
|||||||
InstanceContextHolder.setAdditional("stopping");
|
InstanceContextHolder.setAdditional("stopping");
|
||||||
log.info("程序正在关闭中, 可能需要一定时间.");
|
log.info("程序正在关闭中, 可能需要一定时间.");
|
||||||
scheduledThreadPoolExecutor.shutdown();
|
scheduledThreadPoolExecutor.shutdown();
|
||||||
|
scheduledProvider.close();
|
||||||
log.info("已关闭.");
|
log.info("已关闭.");
|
||||||
InstanceContextHolder.clearAdditional();
|
InstanceContextHolder.clearAdditional();
|
||||||
}, "DDNS-ShutDownHook"));
|
}, "DDNS-ShutDownHook"));
|
||||||
|
|||||||
@@ -17,7 +17,7 @@ import java.util.function.Consumer;
|
|||||||
* @version 1.0.3
|
* @version 1.0.3
|
||||||
* @since 2024/11/25
|
* @since 2024/11/25
|
||||||
*/
|
*/
|
||||||
public class ScheduledProvider extends AbstractProvider {
|
public class ScheduledProvider extends AbstractProvider implements AutoCloseable {
|
||||||
|
|
||||||
private final Provider internalProvider;
|
private final Provider internalProvider;
|
||||||
|
|
||||||
@@ -55,6 +55,11 @@ public class ScheduledProvider extends AbstractProvider {
|
|||||||
this(internalProvider, 60);
|
this(internalProvider, 60);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void close() {
|
||||||
|
poolExecutor.shutdown();
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String get() {
|
public String get() {
|
||||||
return internalCache;
|
return internalCache;
|
||||||
|
|||||||
Reference in New Issue
Block a user