DThd.hxx

浏览该文件的文档.

 
#ifndef __xwos_cxx_DThd_hxx__
#define __xwos_cxx_DThd_hxx__
 
#include <xwos/osal/thd.hxx>
#include <xwos/cxx/Cpu.hxx>
 
namespace xwos {
 
template<xwid_t TCpu = 0>
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)
        : mThdDesc{ nullptr, 0 }
    {
        struct xwos_thd_attr attr({
            .name = name,
            .stack = (xwstk_t *)NULL,
            .stack_size = stack_size,
            .stack_guard_size = stack_guard_size,
            .priority = priority,
            .detached = detached,
            .privileged = privileged,
            });
        mCtorRc = xwos_thd_create(&mThdDesc, &attr, nullptr, nullptr);
    }
    virtual ~DThd() { xwos_thd_detach(mThdDesc); }
    void launch()
    {
        xwer_t rc;
 
        if (TCpu == Cpu::getLocalCpuId()) {
            rc = xwos_thd_launch(mThdDesc, (xwos_thd_f)sThdMainFunction, this);
        } else {
            rc = -EHOSTUNREACH;
        }
        return rc;
    }
    xwer_t getDThdCtorRc() { 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() { return XWOK; }
 
    /* 只能在当前线程函数中调用的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) { return thd->thdMainFunction(); }
};
 
} // namespace xwos
 
#endif /* xwos/cxx/DThd.hxx */