jztools.parallelization.threading.lock

Functions

lock_or_fail(lock, timeout[, message, extra])
lock_or_fail_if_not_none(lock, timeout[, ...])
wait_for_loop(condition, timeout, predicate, ...)	Loops until the condition is met or the exit event is set.
wait_for_or_fail(condition, timeout, predicate)	Example:
wait_or_fail(condition, timeout[, message, ...])	Example:

Exceptions

AcquireTimedOut
TimedOut

exception jztools.parallelization.threading.lock.TimedOut

Bases: Exception

exception jztools.parallelization.threading.lock.AcquireTimedOut

Bases: TimedOut

jztools.parallelization.threading.lock.wait_or_fail(condition, timeout, message=None, extra='')

Example:

with condition: #Acquires lock
    wait_or_fail(condition,1.0) # Will fail or continue with acquired lock
    ...

jztools.parallelization.threading.lock.wait_for_or_fail(condition, timeout, predicate, message=None, extra='')

Example:

with condition: #Acquires lock
    wait_for_or_fail(condition,1.0, lambda: True) # Will fail or continue with acquired lock
    ...

jztools.parallelization.threading.lock.wait_for_loop(condition, timeout, predicate, exit_events)

Loops until the condition is met or the exit event is set. The exit event is checked every timeout seconds. Param exit_event is a dictionary of events, with the key being a user-friendly name.