---

TAO_CEC_MT_Dispatching Class Reference

Dispatching strategy that minimizes mt inversion. More...

#include <CEC_MT_Dispatching.h>

Inheritance diagram for TAO_CEC_MT_Dispatching:

[legend]Collaboration diagram for TAO_CEC_MT_Dispatching:

[legend]List of all members.

Public Methods
	TAO_CEC_MT_Dispatching (int nthreads, int thread_creation_flags, int thread_priority, int force_activate)
	Constructor It will create <nthreads> servicing threads... More...
virtual void	activate (void)
	Initialize all the data structures, activate any internal threads, etc. More...
virtual void	shutdown (void)
	Deactivate any internal threads and cleanup internal data structures, it should only return once the threads have finished their jobs. More...
virtual void	push (TAO_CEC_ProxyPushSupplier *proxy, const CORBA::Any &event ACE_ENV_ARG_DECL)
	The consumer represented by <proxy> should receive <event>. More...
virtual void	push_nocopy (TAO_CEC_ProxyPushSupplier *proxy, CORBA::Any &event ACE_ENV_ARG_DECL)
Private Attributes
ACE_Thread_Manager	thread_manager_
	Use our own thread manager. More...
int	nthreads_
	The number of active tasks. More...
int	thread_creation_flags_
	The flags (THR_BOUND, THR_NEW_LWP, etc.) used to create the dispatching threads. More...
int	thread_priority_
	The priority of the dispatching threads. More...
int	force_activate_
	If activation at the requested priority fails then we fallback on the defaults for thread activation. More...
TAO_CEC_Dispatching_Task	task_
	The dispatching task. More...
TAO_SYNCH_MUTEX	lock_
	Synchronize access to internal data. More...
int	active_
	Are the threads running? More...

---

Detailed Description

Dispatching strategy that minimizes mt inversion.

This strategy uses a single queue, serviced by one or more threads. It's main purpose is to decouple the suppliers from the client execution time, specially in the collocated case.

---

Constructor & Destructor Documentation

TAO_CEC_MT_Dispatching::TAO_CEC_MT_Dispatching (  int    nthreads, int    thread_creation_flags, int    thread_priority, int    force_activate )

Constructor It will create <nthreads> servicing threads...

---

Member Function Documentation

void TAO_CEC_MT_Dispatching::activate (  void    )  [virtual]

Initialize all the data structures, activate any internal threads, etc. Reimplemented from TAO_CEC_Dispatching.

void TAO_CEC_MT_Dispatching::push (  TAO_CEC_ProxyPushSupplier *    proxy, const CORBA::Any &event    ACE_ENV_ARG_DECL )  [virtual]

The consumer represented by <proxy> should receive <event>. Reimplemented from TAO_CEC_Dispatching.

void TAO_CEC_MT_Dispatching::push_nocopy (  TAO_CEC_ProxyPushSupplier *    proxy, CORBA::Any &event    ACE_ENV_ARG_DECL )  [virtual]

Reimplemented from TAO_CEC_Dispatching.

void TAO_CEC_MT_Dispatching::shutdown (  void    )  [virtual]

Deactivate any internal threads and cleanup internal data structures, it should only return once the threads have finished their jobs. Reimplemented from TAO_CEC_Dispatching.

---

Member Data Documentation

int TAO_CEC_MT_Dispatching::active_ [private]

Are the threads running?

int TAO_CEC_MT_Dispatching::force_activate_ [private]

If activation at the requested priority fails then we fallback on the defaults for thread activation.

TAO_SYNCH_MUTEX TAO_CEC_MT_Dispatching::lock_ [private]

Synchronize access to internal data.

int TAO_CEC_MT_Dispatching::nthreads_ [private]

The number of active tasks.

TAO_CEC_Dispatching_Task TAO_CEC_MT_Dispatching::task_ [private]

The dispatching task.

int TAO_CEC_MT_Dispatching::thread_creation_flags_ [private]

The flags (THR_BOUND, THR_NEW_LWP, etc.) used to create the dispatching threads.

ACE_Thread_Manager TAO_CEC_MT_Dispatching::thread_manager_ [private]

Use our own thread manager.

int TAO_CEC_MT_Dispatching::thread_priority_ [private]

The priority of the dispatching threads.

---

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

• CEC_MT_Dispatching.h
• CEC_MT_Dispatching.cpp

---