Function lockShared [src]

Prototype

pub fn lockShared(rwl: *DefaultRwLock) void

Parameters

rwl: *DefaultRwLock

Source

  pub fn lockShared(rwl: *DefaultRwLock) void {
    var state = @atomicLoad(usize, &rwl.state, .seq_cst);
    while (state & (IS_WRITING | WRITER_MASK) == 0) {
        state = @cmpxchgWeak(
            usize,
            &rwl.state,
            state,
            state + READER,
            .seq_cst,
            .seq_cst,
        ) orelse return;
    }

    rwl.mutex.lock();
    _ = @atomicRmw(usize, &rwl.state, .Add, READER, .seq_cst);
    rwl.mutex.unlock();
}  