diff options
Diffstat (limited to 'ace/Activation_Queue.h')
| -rw-r--r-- | ace/Activation_Queue.h | 63 |
1 files changed, 63 insertions, 0 deletions
diff --git a/ace/Activation_Queue.h b/ace/Activation_Queue.h new file mode 100644 index 00000000000..2ab871dce7e --- /dev/null +++ b/ace/Activation_Queue.h @@ -0,0 +1,63 @@ +/* -*- C++ -*- */ +// $Id$ + + +// ============================================================================ +// +// = LIBRARY +// ace +// +// = FILENAME +// Activation_Queue.h +// +// = AUTHOR +// Andres Kruse <Andres.Kruse@cern.ch> and Douglas C. Schmidt +// <schmidt@cs.wustl.edu> +// +// ============================================================================ + +#if !defined (ACE_ACTIVATION_QUEUE_H) +#define ACE_ACTIVATION_QUEUE_H + +#include "ace/Synch.h" +#include "ace/Message_Queue.h" +#include "ace/Method_Object.h" + +class ACE_Export ACE_Activation_Queue + // = TITLE + // Reifies a method into an object. Subclasses typically + // represent necessary state and behavior. + // + // = DESCRIPTION + // A <Method_Object> is inserted in the <Activation_Queue>, where + // it is subsequently removed by the <Scheduler> and invoked. +{ +public: + // = Initialization and termination methods. + ACE_Activation_Queue (ACE_Message_Queue<ACE_SYNCH> *new_queue = 0); + ~ACE_Activation_Queue (void); + + // = Queue operations. + ACE_Method_Object *dequeue (ACE_Time_Value *tv = 0); + // Dequeue the next available <Method_Object>. + + int enqueue (ACE_Method_Object *new_method_object, + ACE_Time_Value *tv = 0); + // Enqueue the <Method_Object>. + + void dump (void) const; + // Dump the state of an object. + + ACE_ALLOC_HOOK_DECLARE; + // Declare the dynamic allocation hooks. + +private: + ACE_Message_Queue<ACE_SYNCH> *queue_; + // Stores the <Method_Objects>. + + int delete_queue_; + // Keeps track of whether we need to delete the queue. +}; + +#endif /* ACE_ACTIVATION_QUEUE_H */ + |