threadex.h

Go to the documentation of this file.

#pragma once

#include "threading.h"
#include <thread>
#include <atomic>
#include <mutex>
#include "threadexceptionadapter.h"

BEGIN_NAMESPACE_THREADING

enum class ThreadExPriority : int
{
    idle = 0,
    lowest = 1,
    low = 2,
    normal = 3,
    high = 4,
    highest = 5,
    timeCritical = 6
};

class ThreadEx
{
public:
    ThreadEx();
    virtual ~ThreadEx();

    virtual void start();

    virtual void stop();

    void terminate();

    void waitFor();

    const ThreadExPriority& getPriority() const;

    void setPriority(ThreadExPriority priority);

    std::recursive_mutex& getLock();

    const std::atomic<bool>& getTerminated() const;

    const std::atomic<bool>& getFinished() const;

    bool getStarted() const;

    ThreadExceptionAdapter* getExceptionAdapter();

    void setExceptionAdapter(ThreadExceptionAdapter* exceptionAdapter);

    const std::thread::id getThreadId() const;

protected:
    std::recursive_mutex lock;
    std::atomic<bool> terminated;
    std::atomic<bool> finished;
    ThreadExceptionAdapter* exceptionAdapter{};

    virtual void execute() = 0;

    void setThreadName(const char* name);

private:
    std::unique_ptr<std::thread> currentThread;
    ThreadExPriority priority;
    void mainThread();
};

END_NAMESPACE_THREADING