Processor.h

#ifndef CMR_PROCESSOR_H_INCLUDED
#define CMR_PROCESSOR_H_INCLUDED

#include "Action.h"
#include "ActionGroup.h"

namespace commore
{
    typedef bool (*ProcessFunction)(void*);
    
    class CMREXD Processor
    {
    public:
        struct HImpl;
    private:
        HImpl* himpl_;
    public:
        Processor(const char* name, const int nb_max_thread, int min_thread);
        Processor(const int nb_max_thread, int min_thread);
        ~Processor();
        Processor(const Processor&);
        Processor& operator = (const Processor&);

        bool start(const char* name, int min_thread = 0, int max_thread = 64);
    public:
        bool submit(const PAction& action);

        bool submit(ActionGroup& actions);

        bool submit(ProcessFunction f, void* p);
        
        void remove_from_submitted_action(const PAction& action);

        void pause();

        void resume();

        bool stop();

        void abort();

        const AString& get_name() const;
        
        bool waitAction(const PAction& action, const int nTimeOut_ms = 0);
        
        void waitIdle();

        void terminate(); 
        
        static Processor& getDefaultProcessor();
    };

}

#endif //CMR_PROCESSOR_H_INCLUDED