Represents a threading.Condition.
(
lock: threading.Lock, condition_class: Optional[Any] = None
)
| 59 | |
| 60 | |
| 61 | def _create_condition( |
| 62 | lock: threading.Lock, condition_class: Optional[Any] = None |
| 63 | ) -> threading.Condition: |
| 64 | """Represents a threading.Condition.""" |
| 65 | if condition_class: |
| 66 | return condition_class(lock) |
| 67 | return threading.Condition(lock) |
| 68 | |
| 69 | |
| 70 | def _async_create_condition(lock: Lock, condition_class: Optional[Any] = None) -> Condition: |