Function gated

tests/test_read_write_unit.py:670–674

(*, blocking: bool, timeout: float)

    errors: dict[str, RuntimeError] = {}

    def gated(*, blocking: bool, timeout: float) -> None:
        if threading.get_ident() == writer_tid.get("id"):  # writer has passed its early check at lock_level == 0
            writer_at_gate.set()
            reader_acquired.wait(5)  # let the reader fully acquire (and open its transaction) first
        real_acquire_tx(blocking=blocking, timeout=timeout)

    def acquire_write_in_thread() -> None:
        writer_tid["id"] = threading.get_ident()