Action.h

Go to the documentation of this file.

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

#ifndef CMR_ACTION_H_INCLUDED
#define CMR_ACTION_H_INCLUDED

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


namespace commore
{
    class Processor;
    class ThreadItem;
    struct ThreadActor;

    class CMREXD Action : public commore::RefObject
    {
        friend class ProcessorImpl;
        friend class ThreadItem;
        friend struct ThreadActor;  // new impl
    public:
        Action();
        virtual ~Action();

    public:
        virtual void run();

        void submit(Processor& processor);

        void stop(Processor& processor, bool wait = true);
        void abort(Processor& processor, bool wait = true);

        bool is_to_stop();
        bool is_to_abort();
        bool is_running();
        bool is_stopped();

        int wait(Processor& processor, const int timeout_ms = 0);

        void reset();

        commore::CriticalSection* get_cs();

    private:
        void run_();

        void set_submitted();
        void unset_submitted();
        void setAbort();
        void set_to_abort();
        void setStop();
        void set_to_stop();
    private:
        struct Impl;
        Impl* impl_;
    };
    typedef commore::AutoRef<Action> PAction;
};
#endif //CMR_ACTION_H_INCLUDED