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:

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...

Accessors
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_
ACE_Time_Value const	dynamic_thread_time_
TAO_Thread_Lane **	lanes_
CORBA::ULong	number_of_lanes_
bool	with_lanes_
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

Detailed Description

Class representing the thread pool inside a thread pool manager.

Constructor & Destructor Documentation

TAO_Thread_Pool() [1/2]

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() [2/2]

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::~TAO_Thread_Pool

(

void

)

Destructor.

Member Function Documentation

allow_borrowing()

CORBA::Boolean TAO_Thread_Pool::allow_borrowing ( void  ) const

inline

allow_request_buffering()

CORBA::Boolean TAO_Thread_Pool::allow_request_buffering ( void  ) const

inline

create_static_threads()

int TAO_Thread_Pool::create_static_threads

(

void

)

Create the static threads - only called once.

finalize()

void TAO_Thread_Pool::finalize

(

void

)

Finalize the resources.

id()

CORBA::ULong TAO_Thread_Pool::id ( void  ) const

inline

is_collocated()

int TAO_Thread_Pool::is_collocated

(

const TAO_MProfile &

mprofile

)

Does mprofile belong to us?

lanes()

TAO_Thread_Lane ** TAO_Thread_Pool::lanes ( void  )

inline

manager()

TAO_Thread_Pool_Manager & TAO_Thread_Pool::manager ( void  ) const

inline

max_buffered_requests()

CORBA::ULong TAO_Thread_Pool::max_buffered_requests ( void  ) const

inline

max_request_buffer_size()

CORBA::ULong TAO_Thread_Pool::max_request_buffer_size ( void  ) const

inline

number_of_lanes()

CORBA::ULong TAO_Thread_Pool::number_of_lanes ( void  ) const

inline

open()

void TAO_Thread_Pool::open

(

void

)

Open the pool.

shutdown_reactor()

void TAO_Thread_Pool::shutdown_reactor

(

void

)

Shutdown the reactor.

shutting_down()

void TAO_Thread_Pool::shutting_down

(

void

)

Mark this thread pool that we are shutting down.

stack_size()

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

inline

wait()

void TAO_Thread_Pool::wait

(

void

)

Wait for threads to exit.

with_lanes()

bool TAO_Thread_Pool::with_lanes ( void  ) const

inline

Check if this thread pool has (explicit) lanes.

Member Data Documentation

allow_borrowing_

CORBA::Boolean TAO_Thread_Pool::allow_borrowing_

private

allow_request_buffering_

CORBA::Boolean TAO_Thread_Pool::allow_request_buffering_

private

dynamic_thread_time_

ACE_Time_Value const TAO_Thread_Pool::dynamic_thread_time_

private

id_

CORBA::ULong TAO_Thread_Pool::id_

private

lanes_

TAO_Thread_Lane** TAO_Thread_Pool::lanes_

private

manager_

TAO_Thread_Pool_Manager& TAO_Thread_Pool::manager_

private

max_buffered_requests_

CORBA::ULong TAO_Thread_Pool::max_buffered_requests_

private

max_request_buffer_size_

CORBA::ULong TAO_Thread_Pool::max_request_buffer_size_

private

number_of_lanes_

CORBA::ULong TAO_Thread_Pool::number_of_lanes_

private

stack_size_

CORBA::ULong TAO_Thread_Pool::stack_size_

private

with_lanes_

bool TAO_Thread_Pool::with_lanes_

private

---

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

• Thread_Pool.h
• Thread_Pool.cpp
• Thread_Pool.inl