TAO/tests/RTScheduling/Current/Thread_Task.h

   1 #ifndef THREAD_TASK_H
   2 #define THREAD_TASK_H
   3
   4 #include "tao/RTScheduling/RTScheduler.h"
   5 #include "tao/ORB.h"
   6 #include "ace/Task.h"
   7
   8
   9 class Thread_Task : public ACE_Task <ACE_SYNCH>
  10 {
  11  public:
  12   Thread_Task (CORBA::ORB_ptr orb);
  13
  14   int activate_task (int thr_count);
  15
  16   ~Thread_Task ();
  17
  18  protected:
  19   /// task svc
  20   virtual int svc ();
  21  private:
  22   CORBA::ORB_var orb_;
  23  RTScheduling::Current_var current_;
  24  int active_thread_count_;
  25  TAO_SYNCH_MUTEX* shutdown_lock_;
  26  TAO_SYNCH_MUTEX* lock_;
  27 };
  28
  29 #endif /* THREAD_TASK_H */