SMtx.hxx

浏览该文件的文档.

 
#ifndef __xwos_cxx_lock_SMtx_hxx__
#define __xwos_cxx_lock_SMtx_hxx__
 
#include <xwos/osal/lock/mtx.hxx>
#include <xwos/cxx/sync/Cond.hxx>
 
namespace xwos {
namespace lock {
 
class SMtx
{
  public:
    enum LockMode : xwu32_t {
        SMtxUnlock = 0, 
        SMtxLock, 
        SMtxLockTimed, 
        SMtxLockUninterruptable, 
        SMtxLockTry, 
    };
 
    class Grd
    {
      private:
        SMtx * mMtx;
        xwer_t mRc; 
        enum LockMode mLockMode;
 
      public:
        Grd() = delete;
 
        Grd(SMtx * mtx, enum LockMode mode = LockMode::SMtxLock, xwtm_t to = XWTM_MAX);
 
        Grd(SMtx & mtx, enum LockMode mode = LockMode::SMtxLock, xwtm_t to = XWTM_MAX);
 
        ~Grd();
 
        xwer_t getRc() { return mRc; }
 
        enum LockMode getLockMode() { return mLockMode; }
 
        xwer_t wait(sync::Cond * cond);
 
        xwer_t wait(sync::Cond & cond) { return wait(&cond); }
 
        xwer_t wait(sync::Cond * cond, xwtm_t to);
 
        xwer_t wait(sync::Cond & cond, xwtm_t to) { return wait(&cond, to); }
    };
 
  private:
    struct xwos_mtx mLock; 
    xwer_t mCtorRc; 
  public:
    explicit SMtx(xwpr_t pr = XWOS_SKD_PRIORITY_RT_MAX);
    ~SMtx(); 
    xwer_t getCtorRc() { return mCtorRc; } 
    struct xwos_mtx * getXwosObj() { return &mLock; } 
    /* 生命周期管理 */
    xwer_t grab() { return xwos_mtx_grab(&mLock); } 
    xwer_t put() { return xwos_mtx_put(&mLock); } 
  private:
    static void * operator new(xwsz_t sz) = delete;
    void operator delete(void * obj) = delete;
};
 
} // namespace lock
} // namespace xwos
 
#endif /* xwos/cxx/lock/SMtx.hxx */