mn_timed_lock.hpp

Go to the documentation of this file.

 
#ifndef MINLIB_ESP32_TIMED_LOCK_
#define MINLIB_ESP32_TIMED_LOCK_
 
#include "mn_config.hpp"
 
#if MN_THREAD_CONFIG_CONDITION_VARIABLE_SUPPORT == MN_THREAD_CONFIG_YES
    #include "mn_convar.hpp"
    #include "mn_convar_task.hpp"
    #include "mn_autolock.hpp"
 
namespace mn {
    template<class TLOCK>
    class basic_timed_lock {
    public:
        basic_timed_lock()
            : m_cv(), m_lockObject(), m_bLocked(false)  { }
        ~basic_timed_lock() {
            basic_autolock<TLOCK> lock(m_lockObject);
        }
        void lock(basic_convar_task& task, unsigned int timeout = MN_THREAD_CONFIG_TIMEOUT_MUTEX_DEFAULT) {
            basic_autolock<TLOCK> lock(m_lockObject);
            while (m_bLocked) {
                task.wait(m_cv, m_mutex, timeout);
            }
            m_bLocked = true;
        }
        void unlock(bool signal_childs = true) {
            basic_autolock<TLOCK> lock(m_lockObject);
            m_bLocked = false;
            m_cv.signal(signal_childs);
        }
    private:
            convar_t    m_cv;
            TLOCK       m_lockObject;
            bool        m_bLocked;
    };
 
    using timed_mutex_t                   = basic_timed_lock<mutex_t>;
    using timed_binary_semaphore_t        = basic_timed_lock<binary_semaphore_t>;
    using timed_counting_semaphore_t      = basic_timed_lock<counting_semaphore_t>;
 
}
#if MN_THREAD_CONFIG_RECURSIVE_MUTEX == MN_THREAD_CONFIG_YES
    using timed_remutex_t = basic_timed_lock<remutex_t>;
#endif //MN_THREAD_CONFIG_RECURSIVE_MUTEX
 
#endif //MN_THREAD_CONFIG_CONDITION_VARIABLE_SUPPORT
#endif //MINLIB_ESP32_TIMED_LOCK_