TAO_RTCORBA  2.2.8
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | Private Attributes | List of all members
TAO_Thread_Pool Class Reference

Class representing the thread pool inside a thread pool manager. More...

#include <Thread_Pool.h>

Collaboration diagram for TAO_Thread_Pool:
Collaboration graph

Public Member Functions

 TAO_Thread_Pool (TAO_Thread_Pool_Manager &manager, CORBA::ULong id, CORBA::ULong stack_size, CORBA::ULong static_threads, CORBA::ULong dynamic_threads, CORBA::Short default_priority, CORBA::Boolean allow_request_buffering, CORBA::ULong max_buffered_requests, CORBA::ULong max_request_buffer_size, TAO_RT_ORBInitializer::TAO_RTCORBA_DT_LifeSpan lifespan, ACE_Time_Value const &dynamic_thread_time)
 Constructor (for pools without lanes). More...
 
 TAO_Thread_Pool (TAO_Thread_Pool_Manager &manager, CORBA::ULong id, CORBA::ULong stack_size, const RTCORBA::ThreadpoolLanes &lanes, CORBA::Boolean allow_borrowing, CORBA::Boolean allow_request_buffering, CORBA::ULong max_buffered_requests, CORBA::ULong max_request_buffer_size, TAO_RT_ORBInitializer::TAO_RTCORBA_DT_LifeSpan lifespan, ACE_Time_Value const &dynamic_thread_time)
 Constructor (for pools with lanes). More...
 
 ~TAO_Thread_Pool (void)
 Destructor. More...
 
void open (void)
 Open the pool. More...
 
void finalize (void)
 Finalize the resources. More...
 
void shutdown_reactor (void)
 Shutdown the reactor. More...
 
void wait (void)
 Wait for threads to exit. More...
 
void shutting_down (void)
 Mark this thread pool that we are shutting down. More...
 
int is_collocated (const TAO_MProfile &mprofile)
 Does mprofile belong to us? More...
 
int create_static_threads (void)
 Create the static threads - only called once. More...
 
bool with_lanes (void) const
 Check if this thread pool has (explicit) lanes. More...
 

Private Attributes

TAO_Thread_Pool_Managermanager_
 
CORBA::ULong id_
 
CORBA::ULong stack_size_
 
CORBA::Boolean allow_borrowing_
 
CORBA::Boolean allow_request_buffering_
 
CORBA::ULong max_buffered_requests_
 
CORBA::ULong max_request_buffer_size_
 
TAO_RT_ORBInitializer::TAO_RTCORBA_DT_LifeSpan
const 
lifespan_
 
ACE_Time_Value const dynamic_thread_time_
 
TAO_Thread_Lane ** lanes_
 
CORBA::ULong number_of_lanes_
 
bool with_lanes_
 

Accessors

TAO_Thread_Pool_Managermanager (void) const
 
CORBA::ULong id (void) const
 
CORBA::ULong stack_size (void) const
 
CORBA::Boolean allow_borrowing (void) const
 
CORBA::Boolean allow_request_buffering (void) const
 
CORBA::ULong max_buffered_requests (void) const
 
CORBA::ULong max_request_buffer_size (void) const
 
TAO_Thread_Lane ** lanes (void)
 
CORBA::ULong number_of_lanes (void) const
 

Detailed Description

Class representing the thread pool inside a thread pool manager.

Constructor & Destructor Documentation

TAO_Thread_Pool::TAO_Thread_Pool ( TAO_Thread_Pool_Manager manager,
CORBA::ULong  id,
CORBA::ULong  stack_size,
CORBA::ULong  static_threads,
CORBA::ULong  dynamic_threads,
CORBA::Short  default_priority,
CORBA::Boolean  allow_request_buffering,
CORBA::ULong  max_buffered_requests,
CORBA::ULong  max_request_buffer_size,
TAO_RT_ORBInitializer::TAO_RTCORBA_DT_LifeSpan  lifespan,
ACE_Time_Value const &  dynamic_thread_time 
)

Constructor (for pools without lanes).

TAO_Thread_Pool::TAO_Thread_Pool ( TAO_Thread_Pool_Manager manager,
CORBA::ULong  id,
CORBA::ULong  stack_size,
const RTCORBA::ThreadpoolLanes lanes,
CORBA::Boolean  allow_borrowing,
CORBA::Boolean  allow_request_buffering,
CORBA::ULong  max_buffered_requests,
CORBA::ULong  max_request_buffer_size,
TAO_RT_ORBInitializer::TAO_RTCORBA_DT_LifeSpan  lifespan,
ACE_Time_Value const &  dynamic_thread_time 
)

Constructor (for pools with lanes).

TAO_Thread_Pool::~TAO_Thread_Pool ( void  )

Destructor.

Member Function Documentation

CORBA::Boolean TAO_Thread_Pool::allow_borrowing ( void  ) const
inline
CORBA::Boolean TAO_Thread_Pool::allow_request_buffering ( void  ) const
inline
int TAO_Thread_Pool::create_static_threads ( void  )

Create the static threads - only called once.

void TAO_Thread_Pool::finalize ( void  )

Finalize the resources.

CORBA::ULong TAO_Thread_Pool::id ( void  ) const
inline
int TAO_Thread_Pool::is_collocated ( const TAO_MProfile mprofile)

Does mprofile belong to us?

TAO_Thread_Lane ** TAO_Thread_Pool::lanes ( void  )
inline
TAO_Thread_Pool_Manager & TAO_Thread_Pool::manager ( void  ) const
inline
CORBA::ULong TAO_Thread_Pool::max_buffered_requests ( void  ) const
inline
CORBA::ULong TAO_Thread_Pool::max_request_buffer_size ( void  ) const
inline
CORBA::ULong TAO_Thread_Pool::number_of_lanes ( void  ) const
inline
void TAO_Thread_Pool::open ( void  )

Open the pool.

void TAO_Thread_Pool::shutdown_reactor ( void  )

Shutdown the reactor.

void TAO_Thread_Pool::shutting_down ( void  )

Mark this thread pool that we are shutting down.

CORBA::ULong TAO_Thread_Pool::stack_size ( void  ) const
inline
void TAO_Thread_Pool::wait ( void  )

Wait for threads to exit.

bool TAO_Thread_Pool::with_lanes ( void  ) const
inline

Check if this thread pool has (explicit) lanes.

Member Data Documentation

CORBA::Boolean TAO_Thread_Pool::allow_borrowing_
private
CORBA::Boolean TAO_Thread_Pool::allow_request_buffering_
private
ACE_Time_Value const TAO_Thread_Pool::dynamic_thread_time_
private
CORBA::ULong TAO_Thread_Pool::id_
private
TAO_Thread_Lane** TAO_Thread_Pool::lanes_
private
TAO_RT_ORBInitializer::TAO_RTCORBA_DT_LifeSpan const TAO_Thread_Pool::lifespan_
private
TAO_Thread_Pool_Manager& TAO_Thread_Pool::manager_
private
CORBA::ULong TAO_Thread_Pool::max_buffered_requests_
private
CORBA::ULong TAO_Thread_Pool::max_request_buffer_size_
private
CORBA::ULong TAO_Thread_Pool::number_of_lanes_
private
CORBA::ULong TAO_Thread_Pool::stack_size_
private
bool TAO_Thread_Pool::with_lanes_
private

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