TAO_RTEvent  2.0.8
Public Member Functions | Private Attributes
TAO_EC_MT_Dispatching Class Reference

Dispatching strategy that minimizes mt inversion. More...

#include <EC_MT_Dispatching.h>

Inheritance diagram for TAO_EC_MT_Dispatching:
Inheritance graph
[legend]
Collaboration diagram for TAO_EC_MT_Dispatching:
Collaboration graph
[legend]

List of all members.

Public Member Functions

 TAO_EC_MT_Dispatching (int nthreads, int thread_creation_flags, int thread_priority, int force_activate, TAO_EC_Queue_Full_Service_Object *queue_full_service_object_name)
virtual void activate (void)
virtual void shutdown (void)
virtual void push (TAO_EC_ProxyPushSupplier *proxy, RtecEventComm::PushConsumer_ptr consumer, const RtecEventComm::EventSet &event, TAO_EC_QOS_Info &qos_info)
virtual void push_nocopy (TAO_EC_ProxyPushSupplier *proxy, RtecEventComm::PushConsumer_ptr consumer, RtecEventComm::EventSet &event, TAO_EC_QOS_Info &qos_info)

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_EC_Dispatching_Task task_
 The dispatching task.
TAO_SYNCH_MUTEX lock_
 Synchronize access to internal data.
int active_
 Are the threads running?
TAO_EC_Queue_Full_Service_Objectqueue_full_service_object_
 Service Object information.

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_EC_MT_Dispatching::TAO_EC_MT_Dispatching ( int  nthreads,
int  thread_creation_flags,
int  thread_priority,
int  force_activate,
TAO_EC_Queue_Full_Service_Object queue_full_service_object_name 
)

Constructor It will create nthreads servicing threads...


Member Function Documentation

void TAO_EC_MT_Dispatching::activate ( void  ) [virtual]

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

Implements TAO_EC_Dispatching.

void TAO_EC_MT_Dispatching::push ( TAO_EC_ProxyPushSupplier proxy,
RtecEventComm::PushConsumer_ptr  consumer,
const RtecEventComm::EventSet event,
TAO_EC_QOS_Info qos_info 
) [virtual]

The consumer represented by proxy should receive event. It can use the information in qos_info to determine the event priority (among other things).

Implements TAO_EC_Dispatching.

void TAO_EC_MT_Dispatching::push_nocopy ( TAO_EC_ProxyPushSupplier proxy,
RtecEventComm::PushConsumer_ptr  consumer,
RtecEventComm::EventSet event,
TAO_EC_QOS_Info qos_info 
) [virtual]

Implements TAO_EC_Dispatching.

void TAO_EC_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_EC_Dispatching.


Member Data Documentation

Are the threads running?

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

Synchronize access to internal data.

The number of active tasks.

Service Object information.

The dispatching task.

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

Use our own thread manager.

The priority of the dispatching threads.


The documentation for this class was generated from the following files:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines