diff options
author | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2005-06-18 18:53:27 +0000 |
---|---|---|
committer | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2005-06-18 18:53:27 +0000 |
commit | 152c0f5c127eac99b5c9097aa4db2b34e14e6dd0 (patch) | |
tree | 0d399a92623e98588cd34e4fe0c2cf7fed880173 /examples/APG/ThreadManagement/Priorities.cpp | |
parent | 7e7f4a5d3e77a42e648b7dd2e1b9cf23a3780955 (diff) | |
download | ATCD-MyACE.tar.gz |
This commit was manufactured by cvs2svn to create branch 'MyACE'.MyACE
Diffstat (limited to 'examples/APG/ThreadManagement/Priorities.cpp')
-rw-r--r-- | examples/APG/ThreadManagement/Priorities.cpp | 104 |
1 files changed, 0 insertions, 104 deletions
diff --git a/examples/APG/ThreadManagement/Priorities.cpp b/examples/APG/ThreadManagement/Priorities.cpp deleted file mode 100644 index 06021432291..00000000000 --- a/examples/APG/ThreadManagement/Priorities.cpp +++ /dev/null @@ -1,104 +0,0 @@ -// $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; - 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 */ |