diff --git a/scripts/data/client2.py b/scripts/data/client2.py index 7db97d0a..9fadfdb0 100644 --- a/scripts/data/client2.py +++ b/scripts/data/client2.py @@ -117,8 +117,9 @@ def job_producer(job_gen): # Notify consumers that a new job is available weight_lock.notify_all() + print("AAAAAAAAAAAAA") + with weight_lock: - weight_lock.wait() weight_lock.notify_all() # Consumer function: Processes blocks from the queue