qxthread.hpp

Go to the documentation of this file.

 
#ifndef QXTHREAD_HPP
#define QXTHREAD_HPP
 
namespace QP {
 
static constexpr std::uint_fast16_t QXTHREAD_NO_TIMEOUT = 0U;
 
//****************************************************************************
class QXThread : public QActive {
public:
 
    QXThread(QXThreadHandler const handler,
             std::uint_fast8_t const tickRate = 0U) noexcept;
 
    static bool delay(std::uint_fast16_t const nTicks) noexcept;
 
    bool delayCancel(void) noexcept;
 
    static QEvt const *queueGet(
        std::uint_fast16_t const nTicks = QXTHREAD_NO_TIMEOUT) noexcept;
 
    // virtual function overrides...
    void init(void const * const e,
              std::uint_fast8_t const qs_id) noexcept override;
    void init(std::uint_fast8_t const qs_id) noexcept override {
        this->init(nullptr, qs_id);
    }
 
    void dispatch(QEvt const * const e,
                  std::uint_fast8_t const qs_id) noexcept override;
 
    void start(std::uint_fast8_t const prio,
               QEvt const * * const qSto, std::uint_fast16_t const qLen,
               void * const stkSto, std::uint_fast16_t const stkSize,
               void const * const par) override;
 
    void start(std::uint_fast8_t const prio,
               QEvt const * * const qSto, std::uint_fast16_t const qLen,
               void * const stkSto, std::uint_fast16_t const stkSize) override
    {
        this->start(prio, qSto, qLen, stkSto, stkSize, nullptr);
    }
 
#ifndef Q_SPY
    bool post_(QEvt const * const e,
               std::uint_fast16_t const margin) noexcept override;
#else
    bool post_(QEvt const * const e, std::uint_fast16_t const margin,
               void const * const sender) noexcept override;
#endif
 
    void postLIFO(QEvt const * const e) noexcept override;
 
private:
    void block_(void) const noexcept;
    void unblock_(void) const noexcept;
    void teArm_(enum_t const sig, std::uint_fast16_t const nTicks) noexcept;
    bool teDisarm_(void) noexcept;
 
    // attributes...
    QTimeEvt m_timeEvt; 
 
    // friendships...
    friend class QXSemaphore;
    friend class QXMutex;
};
 
//****************************************************************************
class QXSemaphore {
public:
    void init(std::uint_fast16_t const count,
              std::uint_fast16_t const max_count = 0xFFFFU) noexcept;
 
    bool wait(std::uint_fast16_t const nTicks = QXTHREAD_NO_TIMEOUT) noexcept;
 
    bool tryWait(void) noexcept;
 
    bool signal(void) noexcept;
 
private:
    QPSet m_waitSet; 
    std::uint16_t volatile m_count;  
    std::uint16_t m_max_count; 
};
 
//****************************************************************************
class QXMutex {
public:
    void init(std::uint_fast8_t const ceiling) noexcept;
 
    bool lock(std::uint_fast16_t const nTicks = QXTHREAD_NO_TIMEOUT) noexcept;
 
    bool tryLock(void) noexcept;
 
    void unlock(void) noexcept;
 
private:
    QPSet m_waitSet; 
    std::uint8_t volatile m_lockNest; 
    std::uint8_t volatile m_holderPrio; 
    std::uint8_t m_ceiling; 
};
 
} // namespace QP
 
#endif // QXTHREAD_HPP