summaryrefslogtreecommitdiff
path: root/ACE/examples/Reactor/WFMO_Reactor/Multithreading.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ACE/examples/Reactor/WFMO_Reactor/Multithreading.cpp')
-rw-r--r--ACE/examples/Reactor/WFMO_Reactor/Multithreading.cpp60
1 files changed, 28 insertions, 32 deletions
diff --git a/ACE/examples/Reactor/WFMO_Reactor/Multithreading.cpp b/ACE/examples/Reactor/WFMO_Reactor/Multithreading.cpp
index 911c3ee9c2e..0212776b0ff 100644
--- a/ACE/examples/Reactor/WFMO_Reactor/Multithreading.cpp
+++ b/ACE/examples/Reactor/WFMO_Reactor/Multithreading.cpp
@@ -1,26 +1,22 @@
-// $Id$
-//
-// ============================================================================
-//
-// = LIBRARY
-// examples
-//
-// = FILENAME
-// Multithreading.cpp
-//
-// = DESCRIPTION
-//
-// This application tests multiple threads simultaneously calling
-// Reactor::handle_events(). It also shows how different threads
-// can update the state of Reactor by registering and removing
-// Event_Handlers.
-//
-// Note that this test will only work with WFMO_Reactor
-//
-// = AUTHOR
-// Irfan Pyarali
-//
-// ============================================================================
+//=============================================================================
+/**
+ * @file Multithreading.cpp
+ *
+ * $Id$
+ *
+ *
+ * This application tests multiple threads simultaneously calling
+ * Reactor::handle_events(). It also shows how different threads
+ * can update the state of Reactor by registering and removing
+ * Event_Handlers.
+ *
+ * Note that this test will only work with WFMO_Reactor
+ *
+ *
+ * @author Irfan Pyarali
+ */
+//=============================================================================
+
#include "ace/OS_main.h"
@@ -32,7 +28,7 @@
#include "ace/Get_Opt.h"
#include "ace/OS_NS_time.h"
-ACE_RCSID(WFMO_Reactor, Multithreading, "$Id$")
+
static int concurrent_threads = 1;
static int number_of_handles = static_cast<int> (ACE_Reactor::instance ()->size ());
@@ -88,31 +84,31 @@ parse_args (int argc, ACE_TCHAR **argv)
class Task_Handler : public ACE_Task<ACE_NULL_SYNCH>
{
public:
+ /// Constructor.
Task_Handler (size_t number_of_handles,
size_t concurrent_threads);
- // Constructor.
+ /// Destructor.
~Task_Handler (void);
- // Destructor.
+ /// Called when object is removed from the ACE_Reactor
virtual int handle_close (ACE_HANDLE handle,
ACE_Reactor_Mask close_mask);
- // Called when object is removed from the ACE_Reactor
+ /// Handle events being signaled by the main thread.
int handle_signal (int signum, siginfo_t * = 0, ucontext_t * = 0);
- // Handle events being signaled by the main thread.
+ /// Called when timer expires.
virtual int handle_timeout (const ACE_Time_Value &tv,
const void *arg = 0);
- // Called when timer expires.
+ /// Task event loop.
int svc (void);
- // Task event loop.
//FUZZ: disable check_for_lack_ACE_OS
+ /// Signal an event.
+ ///FUZZ: enable check_for_lack_ACE_OS
int signal (size_t index);
- // Signal an event.
- //FUZZ: enable check_for_lack_ACE_OS
private:
ACE_Auto_Event *events_;