self.read_coordination_events[expected_element].acquire()
else:
self.write_coordination_events[expected_element].set()
- time.sleep(0.1) # Sleep to consistently "avoid" the race condition.
+ time.sleep(0.5) # Sleep to consistently "avoid" the race condition.
actual_element = sess.run(self.next_element)
if not done_first_event:
done_first_event = True
self.read_coordination_events[expected_element].acquire()
else:
self.write_coordination_events[expected_element].set()
- time.sleep(0.1) # Sleep to consistently "avoid" the race condition.
+ time.sleep(0.5) # Sleep to consistently "avoid" the race condition.
actual_element = sess.run(self.next_element)
if not done_first_event:
done_first_event = True