DThd.hxx

浏览该文件的文档.

 
#ifndef __xwos_cxx_DThd_hxx__
#define __xwos_cxx_DThd_hxx__
 
#include <xwos/osal/thd.hxx>
 
namespace xwos {
 
class DThd
{
  private:
    xwos_thd_d mThdDesc; 
    xwer_t mCtorRc; 
  public:
    DThd(const char * name, xwsz_t stack_size,
         xwsz_t stack_guard_size = XWOS_STACK_GUARD_SIZE_DEFAULT,
         xwpr_t priority = XWOS_SKD_PRIORITY_RT_MIN, bool detached = false,
         bool privileged = true);
    ~DThd(); 
    xwer_t getCtorRc() { return mCtorRc; } 
    xwer_t intr() { return xwos_thd_intr(mThdDesc); } 
    xwer_t quit() { return xwos_thd_quit(mThdDesc); } 
    xwer_t join(xwer_t * trc) { return xwos_thd_join(mThdDesc, trc); } 
    xwer_t stop(xwer_t * trc) { return xwos_thd_stop(mThdDesc, trc); } 
    xwer_t detach() { return xwos_thd_detach(mThdDesc); } 
    struct xwos_thd * getXwosObj() { return mThdDesc.thd; } 
    /* 生命周期管理 */
    xwer_t acquire() { return xwos_thd_acquire(mThdDesc); } 
    xwer_t release() { return xwos_thd_release(mThdDesc); } 
  protected:
    virtual xwer_t thdMainFunction(); 
    /* 只能在当前线程函数中调用的API */
    void yield() { xwos_cthd_yield(); } 
    void exit(xwer_t rc) { xwos_cthd_exit(rc); } 
    bool shouldFreeze() { return xwos_cthd_shld_frz(); } 
    bool shouldStop() { return xwos_cthd_shld_stop(); } 
    xwer_t sleep(xwtm_t dur) { return xwos_cthd_sleep(dur); } 
    xwer_t sleepTo(xwtm_t to) { return xwos_cthd_sleep_to(to); } 
    xwer_t sleepFrom(xwtm_t * from, xwtm_t dur) { return xwos_cthd_sleep_from(from, dur); } 
    xwer_t freeze(void) { return xwos_cthd_shld_stop(); } 
  private:
    static xwer_t sThdMainFunction(DThd * thd);
};
 
} // namespace xwos
 
#endif /* xwos/cxx/DThd.hxx */