Thread.h

//
// Copyright (c) 2006-2014 Raphael David / CANTOR
//

#ifndef CMR_THREAD_INCLUDED
#define CMR_THREAD_INCLUDED

#include "commore/Commore.h"
#include "commore/AutoRef.h"


namespace commore
{
    class ThreadItem;
    class CMREXD Thread
    {
    public:
        struct Impl;
    public:
        Thread() : impl_(0) {}
        virtual ~Thread();

    public:
        bool start();
        bool request_stop();
        bool stop();

        bool is_to_stop();

        bool is_stopped();
        bool is_running();


        virtual void run();

        bool wait(TimePeriod timeout);
        
        bool trigger();
        
        virtual void run_item();
        
    private:
        Impl* impl_;


    };
    
    class CMREXD Event
    {
    public:
        Event(bool create = true);
        Event(const AChar* name);
        ~Event();

    public:
        bool create(const AChar* name = 0);
        bool is_valid();
        bool wait(const TimePeriod& timeout);
        bool wait();
        void signal();
        void reset();
        
        void* get() const { return event_; }

    private:
        Event(const Event&);
        Event& operator = (const Event&);

    private:
        void* event_;
    };


    class CMREXD ThreadContext
    {
    public:
        ThreadContext();
        ~ThreadContext();

    public:
        void* get_value();
        bool set_value(void* v);

    private:
        unsigned long tls_;
        //
        // Ensure false at static init
        //
        bool is_valid_;
    public:
        bool is_valid() const;
        bool isValid() const;
        bool is_used() const;
        bool isUsed() const;
    };
};

#endif