TAO_RTCORBA 2.0.3
|
Class representing the thread pool inside a thread pool manager. More...
#include <Thread_Pool.h>
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). | |
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 (void) | |
Destructor. | |
void | open (void) |
Open the pool. | |
void | finalize (void) |
Finalize the resources. | |
void | shutdown_reactor (void) |
Shutdown the reactor. | |
void | wait (void) |
Wait for threads to exit. | |
void | shutting_down (void) |
Mark this thread pool that we are shutting down. | |
int | is_collocated (const TAO_MProfile &mprofile) |
Does mprofile belong to us? | |
int | create_static_threads (void) |
Create the static threads - only called once. | |
bool | with_lanes (void) const |
Check if this thread pool has (explicit) lanes. | |
Private Attributes | |
TAO_Thread_Pool_Manager & | manager_ |
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_Manager & | manager (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 |
Class representing the thread pool inside a thread pool manager.
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.
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.
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_Thread_Pool_Manager& TAO_Thread_Pool::manager_ [private] |
CORBA::ULong TAO_Thread_Pool::stack_size_ [private] |
bool TAO_Thread_Pool::with_lanes_ [private] |