feat:support config empty protection.

SkyeBeFreeman · SkyeBeFreeman · commit 97a6744053ab · 2025-04-24T22:18:21.000+08:00
diff --git a/polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/RemoteConfigFileRepo.java b/polaris-configuration/polaris-configuration-client/src/main/java/com/tencent/polaris/configuration/client/internal/RemoteConfigFileRepo.java
@@ -192,6 +192,7 @@ protected void doPull() {
                     }
                     if (shouldUpdateLocalCache) {
                         runnable.run();
+                        cancelEmptyProtectionExpireTask();
                     }
                     return;
                 }
@@ -344,6 +345,13 @@ private void submitEmptyProtectionExpireTask(Runnable runnable) {
         }
     }
 
+    private void cancelEmptyProtectionExpireTask() {
+        if (emptyProtectionExpireFuture != null && !emptyProtectionExpireFuture.isCancelled() && !emptyProtectionExpireFuture.isDone()) {
+            emptyProtectionExpireFuture.cancel(true);
+            LOGGER.info("Empty protection expire task of {} cancel.", getIdentifier());
+        }
+    }
+
     @JustForTest
     String getIdentifier() {
         return configFileMetadata.getNamespace() + "."

Original file line number	Diff line number	Diff line change
`@@ -192,6 +192,7 @@ protected void doPull() {`
`192`	`192`	`}`
`193`	`193`	`if (shouldUpdateLocalCache) {`
`194`	`194`	`runnable.run();`
	`195`	`+ cancelEmptyProtectionExpireTask();`
`195`	`196`	`}`
`196`	`197`	`return;`
`197`	`198`	`}`
`@@ -344,6 +345,13 @@ private void submitEmptyProtectionExpireTask(Runnable runnable) {`
`344`	`345`	`}`
`345`	`346`	`}`
`346`	`347`
	`348`	`+ private void cancelEmptyProtectionExpireTask() {`
	`349`	`+ if (emptyProtectionExpireFuture != null && !emptyProtectionExpireFuture.isCancelled() && !emptyProtectionExpireFuture.isDone()) {`
	`350`	`+ emptyProtectionExpireFuture.cancel(true);`
	`351`	`+ LOGGER.info("Empty protection expire task of {} cancel.", getIdentifier());`
	`352`	`+ }`
	`353`	`+ }`
	`354`	`+`
`347`	`355`	`@JustForTest`
`348`	`356`	`String getIdentifier() {`
`349`	`357`	`return configFileMetadata.getNamespace() + "."`