mutex.hpp

Go to the documentation of this file.

#pragma once
#include <common.hpp>
#include <pthread.h>
 
 
namespace rack {
 
 
struct SharedMutex {
    pthread_rwlock_t rwlock;
 
    SharedMutex() {
        int err = pthread_rwlock_init(&rwlock, NULL);
        assert(!err);
    }
    ~SharedMutex() {
        pthread_rwlock_destroy(&rwlock);
    }
 
    void lock() {
        int err = pthread_rwlock_wrlock(&rwlock);
        assert(!err);
    }
    bool try_lock() {
        return pthread_rwlock_trywrlock(&rwlock) == 0;
    }
    void unlock() {
        int err = pthread_rwlock_unlock(&rwlock);
        assert(!err);
    }
 
    void lock_shared() {
        int err = pthread_rwlock_rdlock(&rwlock);
        assert(!err);
    }
    bool try_lock_shared() {
        return pthread_rwlock_tryrdlock(&rwlock) == 0;
    }
    void unlock_shared() {
        unlock();
    }
};
 
 
template <class TMutex>
struct SharedLock {
    TMutex& m;
 
    SharedLock(TMutex& m) : m(m) {
        m.lock_shared();
    }
    ~SharedLock() {
        m.unlock_shared();
    }
};
 
 
} // namespace rack