thread_calc_block.hpp

/* thread_calc_block.hpp */
/* $Id$ */
#ifndef __thread_calc_block_hpp
#define __thread_calc_block_hpp

#include <pthread.h>

#ifdef GE_BUILD
#include <calc_block.hpp>
#else
#include <dcf/calc_block.hpp>
#endif

namespace dcf
{
  class ThreadCalcBlock : public dcf::CalcBlock
  {
  public:
    
    ThreadCalcBlock(const dcf::Manager &manager);
        
    virtual ~ThreadCalcBlock();
    
    virtual void start();
    
    virtual void stop();
    
    virtual void wait();

    int id() const {return m_allocated_unit_id;}

  protected:
    
    virtual void run();
    
    void setStopPoint();
    
    void setThreadStatus(dcf::error_t st);
    
    const dcf::error_t& getThreadStatus();
    
    dcf::error_t releaseUnit();
        
    bool m_ready;                        
  private:
        
    pthread_t m_thread_t;                
    int m_allocated_unit_id;             
    dcf::error_t m_thread_status;        
    ThreadCalcBlock(const dcf::ThreadCalcBlock&);
    
    void operator=(const dcf::ThreadCalcBlock&);
    
    static void* exec(void* me);
  };
};

#endif /* thread_calc_block.hpp */