Thread.h

#pragma once


#include <libutl/host_thread.h>
#include <libutl/NamedObjectMI.h>
#include <libutl/RandUtils.h>
#include <libutl/Uint.h>


UTL_NS_BEGIN;



class Thread : public Object, public NamedObjectMI, protected FlagsMI
{
    UTL_CLASS_DECL_ABC(Thread, Object);
    UTL_CLASS_NO_COPY;

public:
    virtual const Object& getKey() const;

    static Thread* get();

    static thread_handle_t handle();

    size_t
    id() const
    {
        return _id;
    }

    uint_t
    node() const
    {
        return _node;
    }

    uint_t&
    node()
    {
        return _node;
    }

    bool
    isDetached() const
    {
        return getFlag(flg_detached);
    }

    void
    cancel()
    {
        setFlag(flg_cancel, true);
    }

    static void testCancel();

    void* join(bool deleteSelf = true);

    virtual void* run(void* arg = nullptr) = 0;

    void start(void* arg = nullptr, bool join = true);

    static void yield();

    virtual void pause();

    static ulong_t tlsNew();

    static void* tlsGet(ulong_t key);

    static void tlsSet(ulong_t key, void* value);

    randutils::mt19937_64_rng* rng();

#if UTL_HOST_OS != UTL_OS_MINGW
    void setAffinity(size_t cpusetsize, cpu_set_t* cpuset);
#endif

    static void utl_init();

    static void utl_deInit();

protected:
    virtual void onExit();

#if UTL_HOST_OS == UTL_OS_MINGW
    static ulong_t __stdcall runThread(void* vp_runThreadInfo);
#else
    static void* runThread(void* vp_runThreadInfo);
#endif
private:
    void init();
    void deInit();

    void
    setDetached(bool detached)
    {
        setFlag(flg_detached, detached);
    }

private:
    enum flg_t
    {
        flg_detached,
        flg_cancel
    };

private:
    Uint _id;
    uint_t _node;

    randutils::mt19937_64_rng* _rng;
#if UTL_HOST_OS == UTL_OS_MINGW
    void* _threadHandle;
    ulong_t _threadId;
    static ulong_t _objectKey;
#else
    pthread_t _threadHandle;
    static __thread Thread* _thread;
#endif
};


UTL_EXCEPTION_DECL(ThreadCancelledEx, Exception);


UTL_NS_END;