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 getStackInfo(struct xwos_thd_stack_info * stack)
    {
        return xwos_thd_get_stack_info(mThdDesc, stack);
    }
    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_freeze();
    }
 
  private:
    static xwer_t sThdMainFunction(DThd * thd);
};
 
} // namespace xwos
 
#endif /* xwos/cxx/DThd.hxx */