Initial revision

1 files changed, 98 insertions, 0 deletions

diff --git a/tests/Barrier_Test.cpp b/tests/Barrier_Test.cpp
new file mode 100644
index 00000000000..44b7f871214
--- /dev/null
+++ b/tests/Barrier_Test.cpp
@@ -0,0 +1,98 @@
+// ============================================================================
+// @(#)Barrier_Test.cpp	1.1	10/18/96
+
+//
+// = LIBRARY
+//    tests
+// 
+// = FILENAME
+//    Barrier_Test.cpp
+//
+// = DESCRIPTION
+//     This program illustrates how the ACE barrier synchronization
+//     mechanisms work. 
+//
+// = AUTHOR
+//    Prashant Jain and Doug Schmidt
+// 
+// ============================================================================
+
+#include "ace/Log_Msg.h"
+#include "ace/Synch.h"
+#include "ace/Thread_Manager.h"
+#include "ace/Service_Config.h"
+#include "test_config.h"
+
+#if defined (ACE_HAS_THREADS)
+
+struct Tester_Args
+  // = TITLE
+  //     These arguments are passed into each test thread.
+{
+  Tester_Args (ACE_Barrier &tb, int i)
+    : tester_barrier_ (tb), 
+      n_iterations_ (i) {}
+
+  ACE_Barrier &tester_barrier_;
+  // Reference to the tester barrier.  This controls each miteration of
+  // the tester function running in every thread.
+
+  int n_iterations_;
+  // Number of iterations to run.
+};
+
+// Iterate <n_iterations> time printing off a message and "waiting"
+// for all other threads to complete this iteration.
+
+static void *
+tester (Tester_Args *args)
+{
+  ACE_Thread_Control tc (ACE_Service_Config::thr_mgr ()); // Insert thread into thread_manager
+  ACE_NEW_THREAD;
+
+  for (int iterations = 1; 
+       iterations <= args->n_iterations_;
+       iterations++)
+    {
+      ACE_DEBUG ((LM_DEBUG, "(%t) in iteration %d\n", iterations));
+
+      // Block until all other threads have waited, then continue.
+      args->tester_barrier_.wait ();
+    }
+
+  return 0;
+}
+
+int 
+main (int argc, char *argv[])
+{
+  ACE_START_TEST;
+
+  ACE_Service_Config daemon (argv[0]);
+
+  int n_threads = ACE_MAX_THREADS;
+  int n_iterations = ACE_MAX_ITERATIONS;
+
+  ACE_Barrier tester_barrier (n_threads);
+  
+  Tester_Args args (tester_barrier, n_iterations);
+
+  if (ACE_Service_Config::thr_mgr ()->spawn_n 
+      (n_threads, ACE_THR_FUNC (tester), 
+       (void *) &args, THR_NEW_LWP | THR_DETACHED) == -1)
+    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "spawn_n"), 1);
+
+  // Wait for all the threads to reach their exit point.
+  ACE_Service_Config::thr_mgr ()->wait ();
+
+  ACE_END_TEST;
+  return 0;
+}
+#else
+int 
+main (int, char *[])
+{
+  ACE_ERROR ((LM_ERROR, "threads not supported on this platform\n"));
+  return 0;
+}
+#endif /* ACE_HAS_THREADS */