revert the change from RLock

Author: jsonbailey

ldclient/impl/datasystem/store.py

@@ -6,6 +6,7 @@
 ChangeSet applications and flag change notifications.
 """
 
+import threading
 from collections import defaultdict
 from typing import Any, Callable, Dict, List, Optional, Set
 
@@ -193,7 +194,7 @@ def __init__(
         self._selector = Selector.no_selector()
 
         # Thread synchronization
-        self._lock = ReadWriteLock()
+        self._lock = threading.RLock()
 
     def with_persistence(
         self,
@@ -212,7 +213,7 @@ def with_persistence(
         Returns:
             Self for method chaining
         """
-        with self._lock.write():
+        with self._lock:
             self._persistent_store = persistent_store
             self._persistent_store_writable = writable
             self._persistent_store_status_provider = status_provider
@@ -224,12 +225,12 @@ def with_persistence(
 
     def selector(self) -> Selector:
         """Returns the current selector."""
-        with self._lock.read():
+        with self._lock:
             return self._selector
 
     def close(self) -> Optional[Exception]:
         """Close the store and any persistent store if configured."""
-        with self._lock.write():
+        with self._lock:
             if self._persistent_store is not None:
                 try:
                     # Most FeatureStore implementations don't have close methods
@@ -250,7 +251,7 @@ def apply(self, change_set: ChangeSet, persist: bool) -> None:
         """
         collections = self._changes_to_store_data(change_set.changes)
 
-        with self._lock.write():
+        with self._lock:
             try:
                 if change_set.intent_code == IntentCode.TRANSFER_FULL:
                     self._set_basis(collections, change_set.selector, persist)
@@ -442,7 +443,7 @@ def __mapping(data: Dict[str, ModelEntity]) -> Dict[str, Dict[str, Any]]:
 
             return __mapping
 
-        with self._lock.write():
+        with self._lock:
             if self._should_persist():
                 try:
                     # Get all data from memory store and write to persistent store
@@ -456,7 +457,7 @@ def __mapping(data: Dict[str, ModelEntity]) -> Dict[str, Dict[str, Any]]:
 
     def get_active_store(self) -> ReadOnlyStore:
         """Get the currently active store for reading data."""
-        with self._lock.read():
+        with self._lock:
             return self._active_store
 
     def is_initialized(self) -> bool:
@@ -465,5 +466,5 @@ def is_initialized(self) -> bool:
 
     def get_data_store_status_provider(self) -> Optional[DataStoreStatusProvider]:
         """Get the data store status provider for the persistent store, if configured."""
-        with self._lock.read():
+        with self._lock:
             return self._persistent_store_status_provider