kernel_thread_loop.h

Go to the documentation of this file.

#pragma once
#include "kernel_thread.h"
 
 
namespace adtf
{
 
namespace system
{

class kernel_thread_looper: public kernel_thread, public adtf_util::cLooper
{
    public:
        kernel_thread_looper() = default;
 
        kernel_thread_looper(const kernel_thread_looper&) = delete;
 
        template<typename ...Args>
        kernel_thread_looper(const char* strName, Args&&... args): cLooper(std::forward<Args>(args)...)
        {
            *static_cast<kernel_thread*>(this) = kernel_thread(strName, GetCallable());
        }
 
        template<typename ...Args>
        kernel_thread_looper(const adtf::services::IKernel::tSchedulingInfo& sScheduling,
                             const char* strName, Args&&... args): cLooper(std::forward<Args>(args)...)
        {
            *static_cast<kernel_thread*>(this) = kernel_thread(sScheduling, strName, GetCallable());
        }
 
        kernel_thread_looper(kernel_thread_looper&& oOther):
            kernel_thread(static_cast<kernel_thread&&>(oOther)),
            cLooper(static_cast<cLooper&&>(oOther))
        {
        }
 
        kernel_thread_looper& operator=(kernel_thread_looper&& oOther)
        {
            kernel_thread::Swap(oOther);
            cLooper::Swap(oOther);
            return *this;
        }
};

class cKernelThreadLoop
{
    private:
        kernel_thread_looper m_oLooper;
        bool m_bSelfDestruct;
 
    public:
        using tLoopState = adtf_util::cLooper::tLoopState;

        virtual ~cKernelThreadLoop();

        tResult Create(const char *strName, const adtf::services::IKernel::tSchedulingInfo &sScheduling =
                       adtf::services::IKernel::tSchedulingInfo(), bool bSelfDestruct = false,
                       tLoopState eInitialState = tLoopState::Running);

        tResult Release();

        tLoopState GetState();

        tResult SetState(tLoopState eState, bool bWaitForAck = true);
 
    private:
        void Loop();
 
    private:
        void SelfDestruct();
 
    protected:
        virtual tResult LoopFunc() = 0;
};
 
}
 
}