TAO_RTCORBA
2.1.6
|
Class for managing thread pools. More...
#include <Thread_Pool.h>
Public Types | |
typedef ACE_Hash_Map_Manager < RTCORBA::ThreadpoolId, TAO_Thread_Pool *, ACE_Null_Mutex > | THREAD_POOLS |
Collection of thread pools. |
Public Member Functions | |
TAO_Thread_Pool_Manager (TAO_ORB_Core &orb_core) | |
Constructor. | |
~TAO_Thread_Pool_Manager (void) | |
Destructor. | |
void | finalize (void) |
Finalize the resources. | |
void | shutdown_reactor (void) |
Shutdown the reactor. | |
void | wait (void) |
Wait for threads to exit. | |
int | is_collocated (const TAO_MProfile &mprofile) |
Does mprofile belong to us? | |
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. | |
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. | |
void | destroy_threadpool (RTCORBA::ThreadpoolId threadpool) |
Destroy a threadpool. | |
TAO_Thread_Pool * | get_threadpool (RTCORBA::ThreadpoolId thread_pool_id) |
Private Attributes | |
TAO_ORB_Core & | orb_core_ |
THREAD_POOLS | thread_pools_ |
RTCORBA::ThreadpoolId | thread_pool_id_counter_ |
TAO_SYNCH_MUTEX | lock_ |
Accessors | |
TAO_ORB_Core & | orb_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) |
Class for managing thread pools.
typedef ACE_Hash_Map_Manager<RTCORBA::ThreadpoolId, TAO_Thread_Pool *, ACE_Null_Mutex> TAO_Thread_Pool_Manager::THREAD_POOLS |
Collection of thread pools.
TAO_Thread_Pool_Manager::TAO_Thread_Pool_Manager | ( | TAO_ORB_Core & | orb_core | ) |
Constructor.
TAO_Thread_Pool_Manager::~TAO_Thread_Pool_Manager | ( | void | ) |
Destructor.
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.
|
private |
|
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.
|
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.
|
private |
|
private |
|
private |
|
private |