try locking as CS

aerospike · Oct 24, 2024 · ff830d5 · ff830d5
1 parent 9d7fe51
commit ff830d5
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/test/new_tests/test_free_threading.py b/test/new_tests/test_free_threading.py
@@ -15,14 +15,17 @@ def test_unsafe(self):
         THREAD_COUNT = 10
         barrier = threading.Barrier(parties=THREAD_COUNT)
         config = {"hosts": [("127.0.0.1", 3000)]}
+        lock = threading.Lock()
 
         def read_bin():
-            nonlocal barrier, config
+            nonlocal barrier, config, lock
             barrier.wait()
             client = aerospike.client(config)
             _, _, bins = client.get(key)
             nonlocal bin_value_sum
+            lock.acquire()
             bin_value_sum += bins["a"]
+            lock.release()
 
         workers = []
         for _ in range(THREAD_COUNT):