Thread.h

Go to the documentation of this file.

// (c) IMT - Information Management Technology AG, CH-9470 Buchs, www.imt.ch.
 
#ifndef IMT_BASE_OS_LINUX_THREAD_H
#define IMT_BASE_OS_LINUX_THREAD_H
 
#include <atomic>
#include <chrono>
#include <condition_variable>
#include <functional>
#include <Imt.Base.OS.Linux/ThreadSchedulingParams.h>
#include <memory>
#include <mutex>
#include <string>
#include <thread>
 
namespace imt {
namespace base {
namespace os {
namespace linux {
 
class Thread final {
 
public:
 
    Thread(std::string const& threadName, ThreadSchedulingParams schedulingParams, std::function<void()> threadFunction) noexcept;
 
    ~Thread();
 
    void start();
 
    void stop() noexcept;
 
    bool isStopRequested() const noexcept;
 
    constexpr std::mutex& getMutex() noexcept {
        return m_mutex;
    }
 
    constexpr std::condition_variable& getConditionVariable() noexcept {
        return m_condition;
    }
 
    constexpr std::string const& getName() const noexcept {
        return m_threadName;
    }
 
    void waitFor(std::chrono::milliseconds const waitTimeMs);
 
    Thread(Thread const& source) = delete;
    Thread(Thread&& source) noexcept = delete;
    Thread& operator=(Thread const& source) = delete;
    Thread& operator=(Thread&& source) noexcept = delete;
 
private:
 
    void runEndless();
 
    std::string m_threadName;
    ThreadSchedulingParams m_schedulingParams;
    std::function<void()> m_threadFunction;
    std::unique_ptr<std::thread> m_thread;
    // AXIVION Next Line AutosarC++19_03-A12.1.3: All members initialized in constructor
    std::atomic<bool> m_isStopRequested;
    std::mutex m_mutex;
    std::condition_variable m_condition;
};
 
} // namespace linux
} // namespace os
} // namespace base
} // namespace imt
 
#endif // IMT_BASE_OS_LINUX_THREAD_H