TAO_Dynamic_Thread_Pool_Threads Class Reference

Class representing a dynamic thread running in a thread lane. More...

#include <Thread_Pool.h>

Inheritance diagram for TAO_Dynamic_Thread_Pool_Threads:

[legend]Collaboration diagram for TAO_Dynamic_Thread_Pool_Threads:

[legend]List of all members.

Public Member Functions
	TAO_Dynamic_Thread_Pool_Threads (TAO_Thread_Lane &lane)
	Constructor.
Protected Member Functions
virtual int	run (TAO_ORB_Core &orb_core)
	Do the real work.

---

Detailed Description

Class representing a dynamic thread running in a thread lane.

Definition at line 105 of file Thread_Pool.h.

---

Constructor & Destructor Documentation

TAO_Dynamic_Thread_Pool_Threads::TAO_Dynamic_Thread_Pool_Threads

(

TAO_Thread_Lane &

lane

)

Constructor.

Definition at line 98 of file Thread_Pool.cpp.

  : TAO_Thread_Pool_Threads (lane)
{
}

---

Member Function Documentation

int TAO_Dynamic_Thread_Pool_Threads::run

(

TAO_ORB_Core &

orb_core

)

[protected, virtual]

Do the real work.

Reimplemented from TAO_Thread_Pool_Threads.

Definition at line 104 of file Thread_Pool.cpp.

References ACE_DEBUG, ACE_TEXT, TAO_Thread_Lane::dynamic_thread_time(), TAO_ORB_Core::has_shutdown(), TAO_Thread_Lane::id(), TAO_Thread_Pool_Threads::lane_, LM_DEBUG, TAO_ORB_Core::orb(), CORBA::ORB::run(), TAO_debug_level, TAO_RT_ORBInitializer::TAO_RTCORBA_DT_FIXED, TAO_RT_ORBInitializer::TAO_RTCORBA_DT_IDLE, TAO_RT_ORBInitializer::TAO_RTCORBA_DT_INFINITIVE, ACE_Task_Base::thr_count(), and CORBA::ORB::work_pending().

{
  CORBA::ORB_ptr orb = orb_core.orb ();

  switch (this->lane_.lifespan ())
  {
    case TAO_RT_ORBInitializer::TAO_RTCORBA_DT_FIXED :
      {
        ACE_Time_Value tv_run (this->lane_.dynamic_thread_time ());
        orb->run (tv_run);
      }
      break;
    case TAO_RT_ORBInitializer::TAO_RTCORBA_DT_IDLE :
      {
        // A timeout is specified, run the ORB in an idle loop, if we
        // don't handle any operations for the given timeout we just
        // exit the loop and this thread ends itself.
        ACE_Time_Value tv (this->lane_.dynamic_thread_time ());
        while (!orb_core.has_shutdown () && orb->work_pending (tv))
          {
            // Run the ORB for the specified timeout, this prevents looping
            // between work_pending/handle_events
            tv = this->lane_.dynamic_thread_time ();
            orb->run (tv);
            // Reset the idle timeout
            tv = this->lane_.dynamic_thread_time ();
          }
      }
      break;
    case TAO_RT_ORBInitializer::TAO_RTCORBA_DT_INFINITIVE :
      {
        // No timeout specified, run the ORB until it shutdowns
        orb->run ();
      }
      break;
  }

  if (TAO_debug_level > 7)
    {
      ACE_DEBUG ((LM_DEBUG,
                  ACE_TEXT ("TAO Process %P Pool %d Lane %d Thread %t\n")
                  ACE_TEXT ("Current number of dynamic threads left = %d; ")
                  ACE_TEXT ("RTCorba worker thread is ending!\n"),
                  this->lane_.pool ().id (),
                  this->lane_.id (),
                  this->thr_count () - 1));
    }

  return 0;
}

---

The documentation for this class was generated from the following files:

• Thread_Pool.h
• Thread_Pool.cpp

---