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

Class for managing thread pools. More...

#include <Thread_Pool.h>

Collaboration diagram for TAO_Thread_Pool_Manager:
Collaboration graph

Public Types

typedef ACE_Hash_Map_Manager
< RTCORBA::ThreadpoolId,
TAO_Thread_Pool
*, ACE_Null_Mutex
THREAD_POOLS
 Collection of thread pools. More...
 

Public Member Functions

 TAO_Thread_Pool_Manager (TAO_ORB_Core &orb_core)
 Constructor. More...
 
 ~TAO_Thread_Pool_Manager (void)
 Destructor. 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...
 
int is_collocated (const TAO_MProfile &mprofile)
 Does mprofile belong to us? More...
 
RTCORBA::ThreadpoolId create_threadpool (CORBA::ULong stacksize, CORBA::ULong static_threads, CORBA::ULong dynamic_threads, RTCORBA::Priority 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)
 Create a threadpool without lanes. More...
 
RTCORBA::ThreadpoolId create_threadpool_with_lanes (CORBA::ULong stacksize, 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)
 Create a threadpool with lanes. More...
 
void destroy_threadpool (RTCORBA::ThreadpoolId threadpool)
 Destroy a threadpool. More...
 
TAO_Thread_Poolget_threadpool (RTCORBA::ThreadpoolId thread_pool_id)
 

Private Attributes

TAO_ORB_Coreorb_core_
 
THREAD_POOLS thread_pools_
 
RTCORBA::ThreadpoolId thread_pool_id_counter_
 
TAO_SYNCH_MUTEX lock_
 

Accessors

TAO_ORB_Coreorb_core (void) const
 

Helpers

RTCORBA::ThreadpoolId create_threadpool_i (CORBA::ULong stacksize, CORBA::ULong static_threads, CORBA::ULong dynamic_threads, RTCORBA::Priority 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)
 
RTCORBA::ThreadpoolId create_threadpool_with_lanes_i (CORBA::ULong stacksize, 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)
 
RTCORBA::ThreadpoolId create_threadpool_helper (TAO_Thread_Pool *thread_pool)
 

Detailed Description

Class for managing thread pools.

Member Typedef Documentation

Collection of thread pools.

Constructor & Destructor Documentation

TAO_Thread_Pool_Manager::TAO_Thread_Pool_Manager ( TAO_ORB_Core orb_core)

Constructor.

TAO_Thread_Pool_Manager::~TAO_Thread_Pool_Manager ( void  )

Destructor.

Member Function Documentation

RTCORBA::ThreadpoolId TAO_Thread_Pool_Manager::create_threadpool ( CORBA::ULong  stacksize,
CORBA::ULong  static_threads,
CORBA::ULong  dynamic_threads,
RTCORBA::Priority  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 
)

Create a threadpool without lanes.

RTCORBA::ThreadpoolId TAO_Thread_Pool_Manager::create_threadpool_helper ( TAO_Thread_Pool thread_pool)
private
RTCORBA::ThreadpoolId TAO_Thread_Pool_Manager::create_threadpool_i ( CORBA::ULong  stacksize,
CORBA::ULong  static_threads,
CORBA::ULong  dynamic_threads,
RTCORBA::Priority  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 
)
private
RTCORBA::ThreadpoolId TAO_Thread_Pool_Manager::create_threadpool_with_lanes ( CORBA::ULong  stacksize,
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 
)

Create a threadpool with lanes.

RTCORBA::ThreadpoolId TAO_Thread_Pool_Manager::create_threadpool_with_lanes_i ( CORBA::ULong  stacksize,
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 
)
private
void TAO_Thread_Pool_Manager::destroy_threadpool ( RTCORBA::ThreadpoolId  threadpool)

Destroy a threadpool.

void TAO_Thread_Pool_Manager::finalize ( void  )

Finalize the resources.

TAO_Thread_Pool * TAO_Thread_Pool_Manager::get_threadpool ( RTCORBA::ThreadpoolId  thread_pool_id)
int TAO_Thread_Pool_Manager::is_collocated ( const TAO_MProfile mprofile)

Does mprofile belong to us?

TAO_ORB_Core & TAO_Thread_Pool_Manager::orb_core ( void  ) const
void TAO_Thread_Pool_Manager::shutdown_reactor ( void  )

Shutdown the reactor.

void TAO_Thread_Pool_Manager::wait ( void  )

Wait for threads to exit.

Member Data Documentation

TAO_SYNCH_MUTEX TAO_Thread_Pool_Manager::lock_
private
TAO_ORB_Core& TAO_Thread_Pool_Manager::orb_core_
private
RTCORBA::ThreadpoolId TAO_Thread_Pool_Manager::thread_pool_id_counter_
private
THREAD_POOLS TAO_Thread_Pool_Manager::thread_pools_
private

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