diff --git a/test/new_tests/test_free_threading.py b/test/new_tests/test_free_threading.py index 293f80acc..d5fd6e605 100644 --- 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):