Skip to content

Commit

Permalink
close apache#2618
Browse files Browse the repository at this point in the history
  • Loading branch information
haohao0103 committed Aug 13, 2024
1 parent 0b4725f commit ceba46c
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -45,8 +45,8 @@ public abstract class AbstractBackendStoreProvider
private final EventHub storeEventHub = new EventHub("store");

protected Map<String, BackendStore> stores = null;
private static volatile Boolean schemaCacheClearListened = Boolean.FALSE;
private static volatile Boolean vertexEdgeCacheClearListened = Boolean.FALSE;
private static volatile boolean schemaCacheClearListened = false;
private static volatile boolean vertexEdgeCacheClearListened = false;

protected final void notifyAndWaitEvent(String event) {
Future<?> future = this.storeEventHub.notify(event, this);
Expand Down Expand Up @@ -79,7 +79,7 @@ public void listenSchemaCacheClear(EventListener listener) {
synchronized (this) {
if (!schemaCacheClearListened) {
listen(listener);
schemaCacheClearListened = Boolean.TRUE;
schemaCacheClearListened = true;
}
}
}
Expand All @@ -91,7 +91,7 @@ public void listenDataCacheClear(EventListener listener) {
synchronized (this) {
if (!vertexEdgeCacheClearListened) {
listen(listener);
vertexEdgeCacheClearListened = Boolean.TRUE;
vertexEdgeCacheClearListened = true;
}
}
}
Expand Down

0 comments on commit ceba46c

Please sign in to comment.