1 files changed, 104 insertions, 0 deletions
diff --git a/ACE/examples/APG/ThreadManagement/Priorities.cpp b/ACE/examples/APG/ThreadManagement/Priorities.cpp
new file mode 100644
index 00000000000..3a80a613714
--- /dev/null
+++ b/ACE/examples/APG/ThreadManagement/Priorities.cpp
@@ -0,0 +1,104 @@
+// $Id$
+
+#include "ace/config-lite.h"
+
+#if defined (ACE_HAS_THREADS)
+
+#include "ace/Task.h"
+#include "ace/Log_Msg.h"
+#include "ace/OS_NS_unistd.h"
+
+// Listing 2 code/ch13
+class HA_CommandHandler : public ACE_Task<ACE_MT_SYNCH>
+{
+public:
+  HA_CommandHandler (const char *name) : name_ (name)
+  { }
+
+  virtual int svc (void)
+  {
+    ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) starting up %C\n"),
+                name_));
+
+    ACE_OS::sleep (2);
+    ACE_Message_Block *mb = 0;
+    while (this->getq (mb) != -1)
+      {
+        if (mb->msg_type () == ACE_Message_Block::MB_BREAK)
+          {
+            mb->release ();
+            break;
+          }
+        process_message (mb);
+        mb->release ();
+      }
+    return 0;
+  }
+
+  void process_message (ACE_Message_Block *)
+  {
+    ACE_DEBUG ((LM_DEBUG,
+                ACE_TEXT ("(%t) Processing message %C\n"),
+                name_));
+    // Simulate compute bound task.
+    for (int i = 0; i < 100; i++)
+      ;
+  }
+
+private:
+  const char *name_;
+};
+// Listing 2
+
+#if !defined (ACE_THR_PRI_OTHER_MAX)
+// This should be fixed in ACE... There's no _MAX, _MIN values for
+// thread priorities.
+#if defined (ACE_WIN32)
+#  define ACE_THR_PRI_OTHER_MAX ((ACE_THR_PRI_OTHER_DEF) + 1)
+#elif defined (VXWORKS)
+#  define ACE_THR_PRI_OTHER_MAX 0
+#endif
+#endif
+
+// Listing 1 code/ch13
+int ACE_TMAIN (int, ACE_TCHAR *[])
+{
+  HA_CommandHandler hp_handler ("HighPriority");
+  hp_handler.activate (THR_NEW_LWP | THR_JOINABLE,
+                       1, 1, ACE_THR_PRI_OTHER_MAX);
+
+  HA_CommandHandler lp_handler ("LowPriority");
+  lp_handler.activate (THR_NEW_LWP | THR_JOINABLE,
+                       1, 1, ACE_THR_PRI_OTHER_DEF);
+
+  ACE_Message_Block mb;
+  for (int i = 0; i < 100; i++)
+    {
+      ACE_Message_Block *mb_hp, *mb_lp;
+      mb_hp = mb.clone ();
+      mb_lp = mb.clone ();
+      hp_handler.putq (mb_hp);
+      lp_handler.putq (mb_lp);
+    }
+
+  ACE_Message_Block stop (0, ACE_Message_Block::MB_BREAK);
+  hp_handler.putq (stop.clone ());
+  lp_handler.putq (stop.clone ());
+  hp_handler.wait ();
+  lp_handler.wait ();
+
+  return 0;
+}
+// Listing 1
+
+#else
+#include "ace/OS_main.h"
+#include "ace/OS_NS_stdio.h"
+
+int ACE_TMAIN (int, ACE_TCHAR *[])
+{
+  ACE_OS::puts (ACE_TEXT ("This example requires threads."));
+  return 0;
+}
+
+#endif /* ACE_HAS_THREADS */