basicthread.h

Go to the documentation of this file.

 
#pragma once
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_CORE
#include <chrono>
#include <thread>
#include <promeki/atomic.h>
#include <promeki/duration.h>
#include <promeki/error.h>
#include <promeki/function.h>
#include <promeki/set.h>
#include <promeki/string.h>
#include <promeki/uniqueptr.h>
 
PROMEKI_NAMESPACE_BEGIN
 
enum class SchedulePolicy {
        Default,    
        RoundRobin, 
        Fifo,       
        Batch,      
        Idle        
};
 
class BasicThread {
        public:
                using NativeHandle = std::thread::native_handle_type;
 
                using Entry = Function<void()>;
 
                static uint64_t currentNativeId();
 
                static void setCurrentThreadName(const String &name);
 
                static int priorityMin(SchedulePolicy policy = SchedulePolicy::Default);
 
                static int priorityMax(SchedulePolicy policy = SchedulePolicy::Default);
 
                static unsigned int idealThreadCount();
 
                static void sleepNs(int64_t ns);
 
                static void sleepUs(int64_t us);
 
                static void sleepMs(int64_t ms);
 
                static void sleep(const Duration &d) { sleepNs(d.nanoseconds()); }
 
                static void yield();
 
                BasicThread();
 
                explicit BasicThread(const String &name);
 
                BasicThread(BasicThread &&other) noexcept;
 
                BasicThread &operator=(BasicThread &&other) noexcept;
 
                BasicThread(const BasicThread &) = delete;
                BasicThread &operator=(const BasicThread &) = delete;
 
                ~BasicThread();
 
                Error start(Entry entry, size_t stackSize = 0);
 
                Error join();
 
                bool isJoinable() const;
 
                bool isRunning() const;
 
                bool isCurrentThread() const;
 
                String name() const;
 
                void setName(const String &name);
 
                NativeHandle nativeHandle() const;
 
                uint64_t nativeId() const;
 
                std::thread::id id() const;
 
                SchedulePolicy schedulePolicy() const;
 
                int priority() const;
 
                Error setPriority(int prio, SchedulePolicy policy = SchedulePolicy::Default);
 
                Set<int> affinity() const;
 
                Error setAffinity(const Set<int> &cpus);
 
        private:
                struct Data;
                UniquePtr<Data> d;
};
 
template <typename Tag> int nextInstanceId() {
        static Atomic<int> counter{0};
        return counter.fetchAndAdd(1);
}
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_CORE