summaryrefslogtreecommitdiff
path: root/ACE/examples/APG/ThreadSafety/Tokens_Deadlock.cpp
diff options
context:
space:
mode:
authorWilliam R. Otte <wotte@dre.vanderbilt.edu>2006-07-24 15:50:30 +0000
committerWilliam R. Otte <wotte@dre.vanderbilt.edu>2006-07-24 15:50:30 +0000
commitc44379cc7d9c7aa113989237ab0f56db12aa5219 (patch)
tree66a84b20d47f2269d8bdc6e0323f338763424d3a /ACE/examples/APG/ThreadSafety/Tokens_Deadlock.cpp
parent3aff90f4a822fcf5d902bbfbcc9fa931d6191a8c (diff)
downloadATCD-c44379cc7d9c7aa113989237ab0f56db12aa5219.tar.gz
Repo restructuring
Diffstat (limited to 'ACE/examples/APG/ThreadSafety/Tokens_Deadlock.cpp')
-rw-r--r--ACE/examples/APG/ThreadSafety/Tokens_Deadlock.cpp69
1 files changed, 69 insertions, 0 deletions
diff --git a/ACE/examples/APG/ThreadSafety/Tokens_Deadlock.cpp b/ACE/examples/APG/ThreadSafety/Tokens_Deadlock.cpp
new file mode 100644
index 00000000000..f6c6d22491f
--- /dev/null
+++ b/ACE/examples/APG/ThreadSafety/Tokens_Deadlock.cpp
@@ -0,0 +1,69 @@
+// $Id$
+
+#include "ace/Local_Tokens.h"
+#include "ace/Task.h"
+#include "ace/OS_NS_unistd.h"
+
+#if defined (ACE_HAS_TOKENS_LIBRARY)
+
+// Listing 1 code/ch14
+class ThreadOne : public ACE_Task_Base
+{
+public:
+ virtual int svc (void)
+ {
+ ACE_Local_Mutex mutex1 (ACE_TEXT ("resource1"),
+ 0, // Deadlock detection enabled.
+ 1);// Debugging enabled.
+ mutex1.acquire ();
+ ACE_OS::sleep (2);
+ ACE_Local_Mutex mutex2 (ACE_TEXT ("resource2"), 0, 1);
+ mutex2.acquire ();
+ return 0;
+ }
+};
+
+class ThreadTwo : public ACE_Task_Base
+{
+public:
+ virtual int svc (void)
+ {
+ ACE_Local_Mutex mutex2 (ACE_TEXT ("resource2"),
+ 0, // Deadlock detection enabled.
+ 1);// Debugging enabled.
+ mutex2.acquire ();
+ ACE_OS::sleep (2);
+ ACE_Local_Mutex mutex1 (ACE_TEXT ("resource1"),
+ 0, // Deadlock detection enabled.
+ 1);// Debugging enabled.
+ mutex1.acquire ();
+ return 0;
+ }
+};
+
+int ACE_TMAIN (int, ACE_TCHAR *[])
+{
+ ThreadOne t1;
+ ThreadTwo t2;
+
+ t1.activate ();
+ ACE_OS::sleep (1);
+ t2.activate ();
+ t1.wait ();
+ t2.wait ();
+
+ return 0;
+}
+// Listing 1
+
+#else /* defined (ACE_HAS_TOKENS_LIBRARY) */
+
+int ACE_TMAIN (int, ACE_TCHAR *[])
+{
+ ACE_ERROR ((LM_ERROR,
+ ACE_TEXT ("local tokens not supported ")
+ ACE_TEXT ("on this platform\n")));
+ return 0;
+}
+
+#endif /* defined (ACE_HAS_TOKENS_LIBRARY) */