threadimpl.h

Go to the documentation of this file.

/* SPDX-License-Identifier: MIT */
#ifndef AJA_THREAD_IMPL_H
#define AJA_THREAD_IMPL_H
 
#include <pthread.h>
#include "ajabase/system/system.h"
#include "ajabase/common/common.h"
#include "ajabase/system/thread.h"
#include "ajabase/system/lock.h"
 
 
class AJAThreadImpl
{
public:
 
    AJAThreadImpl(AJAThread* pThreadContext);
    virtual ~AJAThreadImpl();
 
    AJAStatus       Start();
 
    AJAStatus       Stop(uint32_t timeout = 0xffffffff);
 
    AJAStatus       Kill(uint32_t exitCode);
 
    bool            Active();
    bool            IsCurrentThread();
 
    AJAStatus       SetPriority(AJAThreadPriority threadPriority);
    AJAStatus       GetPriority(AJAThreadPriority* pThreadPriority);
 
    AJAStatus       SetRealTime(AJAThreadRealTimePolicy policy, int priority);
 
    AJAStatus       Attach(AJAThreadFunction* pThreadFunction, void* pUserContext);
    AJAStatus       SetThreadName(const char *name);
 
    static uint64_t GetThreadId();
    static void*    ThreadProcStatic(void* pThreadImplContext);
 
public:
    AJAThread*          mpThreadContext;
    pthread_t           mThread;
    pid_t               mTid;
    AJAThreadPriority   mPriority;
    AJAThreadFunction*  mThreadFunc;
    void*               mpUserContext;
    AJALock             mLock;
 
    bool                mThreadStarted;
    pthread_mutex_t     mStartMutex;
    pthread_cond_t      mStartCond;
 
    bool                mTerminate;
    bool                mExiting;
    pthread_mutex_t     mExitMutex;
    pthread_cond_t      mExitCond;
};
 
#endif  //  AJA_THREAD_IMPL_H