diff options
Diffstat (limited to 'TAO/tao/Pool_Per_Endpoint.h')
-rw-r--r-- | TAO/tao/Pool_Per_Endpoint.h | 62 |
1 files changed, 30 insertions, 32 deletions
diff --git a/TAO/tao/Pool_Per_Endpoint.h b/TAO/tao/Pool_Per_Endpoint.h index ea8265c3bde..e6b03aabac6 100644 --- a/TAO/tao/Pool_Per_Endpoint.h +++ b/TAO/tao/Pool_Per_Endpoint.h @@ -1,17 +1,14 @@ -// $Id$ - -// ============================================================================ -// -// = LIBRARY -// TAO -// -// = FILENAME -// Pool_Per_Endpoint.h -// -// = AUTHOR -// Carlos O'Ryan (coryan@cs.wustl.edu) -// -// ============================================================================ + +//============================================================================= +/** + * @file Pool_Per_Endpoint.h + * + * $Id$ + * + * @author Carlos O'Ryan (coryan@cs.wustl.edu) + */ +//============================================================================= + #ifndef TAO_POOL_PER_ENDPOINT_H #define TAO_POOL_PER_ENDPOINT_H @@ -26,51 +23,52 @@ #include "ace/Task.h" +/** + * @class TAO_Pool_Per_Endpoint + * + * @brief The Pool_Per_Endpoint concurrency strategy. + * + * This strategy creates a separate thread pool for each endpoint + * in the system. It is a helper class to manage and create the + * required threads. + * It should be used with the Reactor_Per_Endpoint registry + * configured. + */ class TAO_Export TAO_Pool_Per_Endpoint : public ACE_Task_Base { - // = TITLE - // The Pool_Per_Endpoint concurrency strategy. - // - // = DESCRIPTION - // This strategy creates a separate thread pool for each endpoint - // in the system. It is a helper class to manage and create the - // required threads. - // It should be used with the Reactor_Per_Endpoint registry - // configured. - // public: + /// Constructor TAO_Pool_Per_Endpoint (CORBA::ORB_ptr orb, int policy = ACE_SCHED_OTHER, int poolsize = 1, int flags = THR_BOUND|THR_NEW_LWP|THR_JOINABLE); - // Constructor + /// The destructor virtual ~TAO_Pool_Per_Endpoint (void); - // The destructor + /// Run all the threads and wait until they finish void run (CORBA::Environment &ACE_TRY_ENV = TAO_default_environment ()); - // Run all the threads and wait until they finish // = The Task_Base entry point int svc (void); private: + /// The ORB. CORBA::ORB_var orb_; - // The ORB. + /// The scheduling policy to activate the threads. int policy_; - // The scheduling policy to activate the threads. + /// The number of threads on each pool. int poolsize_; - // The number of threads on each pool. + /// The flags used to create the threads int flags_; - // The flags used to create the threads + /// The thread manager. ACE_Thread_Manager thread_manager_; - // The thread manager. }; #if defined (__ACE_INLINE__) |