ACE/examples/APG/ThreadSafety/Tokens_Deadlock.cpp

   1 #include "ace/Local_Tokens.h"
   2 #include "ace/Task.h"
   3 #include "ace/OS_NS_unistd.h"
   4
   5 #if defined (ACE_HAS_TOKENS_LIBRARY)
   6
   7 // Listing 1 code/ch14
   8 class ThreadOne : public ACE_Task_Base
   9 {
  10 public:
  11   virtual int svc ()
  12   {
  13     ACE_Local_Mutex mutex1 (ACE_TEXT ("resource1"),
  14                             0, // Deadlock detection enabled.
  15                             1);// Debugging enabled.
  16     mutex1.acquire ();
  17     ACE_OS::sleep (2);
  18     ACE_Local_Mutex mutex2 (ACE_TEXT ("resource2"), 0, 1);
  19     mutex2.acquire ();
  20     return 0;
  21   }
  22 };
  23
  24 class ThreadTwo : public ACE_Task_Base
  25 {
  26 public:
  27   virtual int svc ()
  28   {
  29     ACE_Local_Mutex mutex2 (ACE_TEXT ("resource2"),
  30                             0, // Deadlock detection enabled.
  31                             1);// Debugging enabled.
  32     mutex2.acquire ();
  33     ACE_OS::sleep (2);
  34     ACE_Local_Mutex mutex1 (ACE_TEXT ("resource1"),
  35                             0, // Deadlock detection enabled.
  36                             1);// Debugging enabled.
  37     mutex1.acquire ();
  38     return 0;
  39   }
  40 };
  41
  42 int ACE_TMAIN (int, ACE_TCHAR *[])
  43 {
  44   ThreadOne t1;
  45   ThreadTwo t2;
  46
  47   t1.activate ();
  48   ACE_OS::sleep (1);
  49   t2.activate ();
  50   t1.wait ();
  51   t2.wait ();
  52
  53   return 0;
  54 }
  55 // Listing 1
  56
  57 #else /* defined (ACE_HAS_TOKENS_LIBRARY) */
  58
  59 int ACE_TMAIN (int, ACE_TCHAR *[])
  60 {
  61   ACE_ERROR ((LM_ERROR,
  62               ACE_TEXT ("local tokens not supported ")
  63               ACE_TEXT ("on this platform\n")));
  64   return 0;
  65 }
  66
  67 #endif /* defined (ACE_HAS_TOKENS_LIBRARY) */