summaryrefslogtreecommitdiff
path: root/libcult/examples/sched/cancel/cancel.cxx
diff options
context:
space:
mode:
Diffstat (limited to 'libcult/examples/sched/cancel/cancel.cxx')
-rw-r--r--libcult/examples/sched/cancel/cancel.cxx63
1 files changed, 63 insertions, 0 deletions
diff --git a/libcult/examples/sched/cancel/cancel.cxx b/libcult/examples/sched/cancel/cancel.cxx
new file mode 100644
index 0000000..ee71449
--- /dev/null
+++ b/libcult/examples/sched/cancel/cancel.cxx
@@ -0,0 +1,63 @@
+// file : examples/sched/cancel/cancel.cxx
+// author : Boris Kolpackov <boris@kolpackov.net>
+// copyright : Copyright (c) 2005-2010 Boris Kolpackov
+// license : GNU GPL v2 + exceptions; see accompanying LICENSE file
+
+#include <cult/types.hxx>
+
+#include <cult/mm/shptr.hxx>
+
+#include <cult/sched/lock.hxx>
+#include <cult/sched/mutex.hxx>
+#include <cult/sched/thread.hxx>
+#include <cult/sched/condition.hxx>
+
+
+#include <iostream>
+#include <unistd.h> // sleep
+
+using std::cerr;
+using std::endl;
+
+using namespace Cult;
+using namespace Sched;
+
+Void*
+cond_wait_thread_proc (Void*)
+{
+ try
+ {
+ Mutex mutex;
+ Condition cond (mutex);
+
+ Lock lock (mutex);
+
+ cond.wait ();
+ }
+ /*
+ catch (std::thread_canceled const& e)
+ {
+ cerr << "caught thread_canceled" << endl;
+ throw;
+ }
+ */
+ catch (...)
+ {
+ cerr << "presumably caught thread_canceled" << endl;
+ throw;
+ }
+
+ return 0;
+}
+
+
+Int
+main ()
+{
+ Shptr<Thread> thread (new Thread (cond_wait_thread_proc));
+
+ sleep (1);
+
+ thread->cancel ();
+ thread->join ();
+}