TAO_Thread_Pool_Manager Class Reference

Class for managing thread pools. More...

#include <Thread_Pool.h>

Collaboration diagram for TAO_Thread_Pool_Manager:

[legend]

List of all members.

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)
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_

---

Detailed Description

Class for managing thread pools.

---

Member Typedef Documentation

typedef ACE_Hash_Map_Manager<RTCORBA::ThreadpoolId, TAO_Thread_Pool *, ACE_Null_Mutex> TAO_Thread_Pool_Manager::THREAD_POOLS

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

void TAO_Thread_Pool_Manager::finalize

(

void

)

Finalize the resources.

void TAO_Thread_Pool_Manager::shutdown_reactor

(

void

)

Shutdown the reactor.

void TAO_Thread_Pool_Manager::wait

(

void

)

Wait for threads to exit.

int TAO_Thread_Pool_Manager::is_collocated

(

const TAO_MProfile &

mprofile

)

Does mprofile belong to us?

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_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 TAO_Thread_Pool_Manager::destroy_threadpool

(

RTCORBA::ThreadpoolId

threadpool

)

Destroy a threadpool.

TAO_Thread_Pool * TAO_Thread_Pool_Manager::get_threadpool

(

RTCORBA::ThreadpoolId

thread_pool_id

)

TAO_ORB_Core & TAO_Thread_Pool_Manager::orb_core

(

void

)

const

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_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]

RTCORBA::ThreadpoolId TAO_Thread_Pool_Manager::create_threadpool_helper

(

TAO_Thread_Pool *

thread_pool

)

[private]

---

Member Data Documentation

TAO_ORB_Core& TAO_Thread_Pool_Manager::orb_core_ [private]

THREAD_POOLS TAO_Thread_Pool_Manager::thread_pools_ [private]

RTCORBA::ThreadpoolId TAO_Thread_Pool_Manager::thread_pool_id_counter_ [private]

TAO_SYNCH_MUTEX TAO_Thread_Pool_Manager::lock_ [private]

---

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

• Thread_Pool.h
• Thread_Pool.cpp