Main Page | Namespace List | Class Hierarchy | Alphabetical List | Class List | File List | Class Members | File Members | Search for 

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:

Inheritance graph
[legend]
Collaboration diagram for TAO_CEC_MT_Dispatching:

Collaboration graph
[legend]
List of all members.

Public Member Functions

 TAO_CEC_MT_Dispatching (int nthreads, int thread_creation_flags, int thread_priority, int force_activate)
virtual void activate (void)
virtual void shutdown (void)
virtual void push (TAO_CEC_ProxyPushSupplier *proxy, const CORBA::Any &event ACE_ENV_ARG_DECL)
 The consumer represented by should receive .

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.

int nthreads_
 The number of active tasks.

int thread_creation_flags_
int thread_priority_
 The priority of the dispatching threads.

int force_activate_
TAO_CEC_Dispatching_Task task_
 The dispatching task.

TAO_SYNCH_MUTEX lock_
 Synchronize access to internal data.

int active_
 Are the threads running?

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.

Definition at line 40 of file CEC_MT_Dispatching.h.

Constructor & Destructor Documentation

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

Constructor It will create servicing threads...

Definition at line 12 of file CEC_MT_Dispatching.cpp. 

00016   :  nthreads_ (nthreads),
00017      thread_creation_flags_ (thread_creation_flags),
00018      thread_priority_ (thread_priority),
00019      force_activate_ (force_activate),
00020      task_ (&this->thread_manager_),
00021      active_ (0)
00022 {
00023 }

Member Function Documentation

void TAO_CEC_MT_Dispatching::activate (  void   )  [virtual]
 

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

Implements TAO_CEC_Dispatching.

Definition at line 26 of file CEC_MT_Dispatching.cpp.

References ACE_ERROR, ACE_GUARD, ACE_Task_Base::activate(), force_activate_, LM_ERROR, and TAO_SYNCH_MUTEX.

Referenced by push_nocopy(). 

00027 {
00028   ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->lock_);
00029 
00030   if (this->active_ != 0)
00031     return;
00032 
00033   this->active_ = 1;
00034 
00035   if (this->task_.activate (this->thread_creation_flags_,
00036                             this->nthreads_,
00037                             1,
00038                             this->thread_priority_) == -1)
00039     {
00040       if (this->force_activate_ != 0)
00041         {
00042           if (this->task_.activate (THR_BOUND, this->nthreads_) == -1)
00043             ACE_ERROR ((LM_ERROR,
00044                         "EC (%P|%t) cannot activate dispatching queue"));
00045         }
00046     }
00047 }

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

The consumer represented by should receive .

Implements TAO_CEC_Dispatching.

Definition at line 65 of file CEC_MT_Dispatching.cpp.

References ACE_ENV_ARG_PARAMETER, and push_nocopy(). 

00068 {
00069   CORBA::Any event_copy = event;
00070   this->push_nocopy (proxy, event_copy ACE_ENV_ARG_PARAMETER);
00071 }

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

Implements TAO_CEC_Dispatching.

Definition at line 74 of file CEC_MT_Dispatching.cpp.

References ACE_ENV_ARG_PARAMETER, activate(), and TAO_CEC_Dispatching_Task::push().

Referenced by push(). 

00077 {
00078   // Double checked locking....
00079   if (this->active_ == 0)
00080     this->activate ();
00081 
00082   this->task_.push (proxy, event ACE_ENV_ARG_PARAMETER);
00083 }

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.

Implements TAO_CEC_Dispatching.

Definition at line 50 of file CEC_MT_Dispatching.cpp.

References ACE_GUARD, nthreads_, ACE_Task< ACE_SYNCH >::putq(), TAO_SYNCH_MUTEX, thread_manager_, and ACE_Thread_Manager::wait(). 

00051 {
00052   ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->lock_);
00053 
00054   if (this->active_ == 0)
00055     return;
00056 
00057   for (int i = 0; i < this->nthreads_; ++i)
00058     {
00059       this->task_.putq (new TAO_CEC_Shutdown_Task_Command);
00060     }
00061   this->thread_manager_.wait ();
00062 }

Member Data Documentation

int TAO_CEC_MT_Dispatching::active_ [private]
 

Are the threads running?

Definition at line 93 of file CEC_MT_Dispatching.h.

int TAO_CEC_MT_Dispatching::force_activate_ [private]
 

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

Definition at line 84 of file CEC_MT_Dispatching.h.

Referenced by activate().

TAO_SYNCH_MUTEX TAO_CEC_MT_Dispatching::lock_ [private]
 

Synchronize access to internal data.

Definition at line 90 of file CEC_MT_Dispatching.h.

int TAO_CEC_MT_Dispatching::nthreads_ [private]
 

The number of active tasks.

Definition at line 73 of file CEC_MT_Dispatching.h.

Referenced by shutdown().

TAO_CEC_Dispatching_Task TAO_CEC_MT_Dispatching::task_ [private]
 

The dispatching task.

Definition at line 87 of file CEC_MT_Dispatching.h.

int TAO_CEC_MT_Dispatching::thread_creation_flags_ [private]
 

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

Definition at line 77 of file CEC_MT_Dispatching.h.

ACE_Thread_Manager TAO_CEC_MT_Dispatching::thread_manager_ [private]
 

Use our own thread manager.

Definition at line 70 of file CEC_MT_Dispatching.h.

Referenced by shutdown().

int TAO_CEC_MT_Dispatching::thread_priority_ [private]
 

The priority of the dispatching threads.

Definition at line 80 of file CEC_MT_Dispatching.h.

The documentation for this class was generated from the following files:
Generated on Thu Nov 9 13:19:31 2006 for TAO_CosEvent by doxygen 1.3.6