update

Author: zhiyuanliang-ms

src/AzureAppConfigurationImpl.ts

@@ -9,7 +9,7 @@ import { IKeyValueAdapter } from "./IKeyValueAdapter.js";
 import { JsonKeyValueAdapter } from "./JsonKeyValueAdapter.js";
 import { DEFAULT_REFRESH_INTERVAL_IN_MS, MIN_REFRESH_INTERVAL_IN_MS } from "./RefreshOptions.js";
 import { Disposable } from "./common/disposable.js";
-import { Lock } from "./common/lock.js";
+import { ExclusiveExecutor } from "./common/mutex.js";
 import { FEATURE_FLAGS_KEY_NAME, FEATURE_MANAGEMENT_KEY_NAME } from "./featureManagement/constants.js";
 import { AzureKeyVaultKeyValueAdapter } from "./keyvault/AzureKeyVaultKeyValueAdapter.js";
 import { RefreshTimer } from "./refresh/RefreshTimer.js";
@@ -41,7 +41,7 @@ export class AzureAppConfigurationImpl implements AzureAppConfiguration {
     #isInitialLoadCompleted: boolean = false;
 
     // Refresh
-    #refreshLock: Lock = new Lock(); // lock to prevent "concurrent" async refresh
+    #refreshExecutor: ExclusiveExecutor = new ExclusiveExecutor();
 
     #refreshInterval: number = DEFAULT_REFRESH_INTERVAL_IN_MS;
     #onRefreshListeners: Array<() => any> = [];
@@ -353,7 +353,7 @@ export class AzureAppConfigurationImpl implements AzureAppConfiguration {
             throw new Error("Refresh is not enabled for key-values or feature flags.");
         }
 
-        await this.#refreshLock.execute(this.#refreshTasks.bind(this));
+        await this.#refreshExecutor.execute(this.#refreshTasks.bind(this));
     }
 
     async #refreshTasks(): Promise<void> {

src/common/lock.ts

@@ -0,0 +1,21 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT license.
+
+export class ExclusiveExecutor {
+    isExecuting = false;
+
+    /**
+     * Execute the given function exclusively. If there is any previous execution in progress, the new execution will be aborted.
+     */
+    async execute(fn) {
+        if (this.isExecuting) {
+            return; // do nothing
+        }
+        this.isExecuting = true;
+        try {
+            await fn();
+        } finally {
+            this.isExecuting = false;
+        }
+    }
+}