priority_mutex_cpl.hpp

Go to the documentation of this file.

 
#ifndef BOOST_FAIRNESS_PRIORITY_MUTEX_CPL_HPP
#define BOOST_FAIRNESS_PRIORITY_MUTEX_CPL_HPP
#include <atomic>
#include <array>
#include <boost/fairness/priority_t.hpp>
#include <boost/fairness/detail/wait_ops.hpp>
#include <boost/fairness/spinlock_priority_mutex.hpp>
#include <boost/fairness/detail/wait_pool.hpp>
#include <boost/fairness/detail/pqlock.hpp>
 
namespace boost::fairness{
 
    template<size_t N = 1>
    requires (N >= 1 && N <= BOOST_FAIRNESS_MAXIMUM_PRIORITY)
    class priority_mutex{
 
        using Thread_cnt_t = uint32_t;
 
        public:
 
        priority_mutex() = default;
 
        priority_mutex(const priority_mutex&) = delete;
 
        priority_mutex& operator=(const priority_mutex&) = delete;
 
        priority_mutex(priority_mutex&&) = delete;
 
        priority_mutex& operator=(priority_mutex&&) = delete;
 
        ~priority_mutex() = default;
 
        void lock(Priority_t const priority = 0){
 
            lll_.lock(priority);
        }
 
        void unlock(){
 
            lll_.unlock();
 
        }
 
        /* The try_lock for the Craig algorithm will be implemented in a future update.
 
        [[nodiscard]] bool try_lock(Priority_t const priority = 0){ // try lock is difficult with the cpr logic
            
            lll_.try_lock(priority);
        }
        */
 
        private:
 
        alignas(BOOST_FAIRNESS_HARDWARE_DESTRUCTIVE_SIZE) detail::pqlock lll_;
 
    };
 
}
#endif // BOOST_FAIRNESS_PRIORITY_MUTEX_CPL_HPP