1 files changed, 73 insertions, 0 deletions
diff --git a/src/boost/libs/thread/example/thread_group.cpp b/src/boost/libs/thread/example/thread_group.cpp
new file mode 100644
index 000000000..1256a1045
--- /dev/null
+++ b/src/boost/libs/thread/example/thread_group.cpp
@@ -0,0 +1,73 @@
+// Copyright (C) 2001-2003
+// William E. Kempf
+//
+//  Distributed under the Boost Software License, Version 1.0. (See accompanying
+//  file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
+
+#include <boost/thread/thread.hpp>
+#include <iostream>
+#include <boost/detail/lightweight_test.hpp>
+
+int count = 0;
+boost::mutex mutex;
+
+void increment_count()
+{
+    boost::unique_lock<boost::mutex> lock(mutex);
+    std::cout << "count = " << ++count << std::endl;
+}
+
+boost::thread_group threads2;
+boost::thread* th2 = 0;
+
+void increment_count_2()
+{
+    boost::unique_lock<boost::mutex> lock(mutex);
+    BOOST_TEST(threads2.is_this_thread_in());
+    std::cout << "count = " << ++count << std::endl;
+}
+
+int main()
+{
+  {
+    boost::thread_group threads;
+    for (int i = 0; i < 3; ++i)
+        threads.create_thread(&increment_count);
+    threads.join_all();
+  }
+#if defined BOOST_THREAD_PROVIDES_INTERRUPTIONS
+  {
+    boost::thread_group threads;
+    for (int i = 0; i < 3; ++i)
+        threads.create_thread(&increment_count);
+    threads.interrupt_all();
+    threads.join_all();
+  }
+#endif
+  {
+    boost::thread_group threads;
+    boost::thread* th = new boost::thread(&increment_count);
+    threads.add_thread(th);
+    BOOST_TEST(! threads.is_this_thread_in());
+    threads.join_all();
+  }
+  {
+    boost::thread_group threads;
+    boost::thread* th = new boost::thread(&increment_count);
+    threads.add_thread(th);
+    BOOST_TEST(threads.is_thread_in(th));
+    threads.remove_thread(th);
+    BOOST_TEST(! threads.is_thread_in(th));
+    th->join();
+    delete th;
+  }
+  {
+    {
+      boost::unique_lock<boost::mutex> lock(mutex);
+      boost::thread* th2 = new boost::thread(&increment_count_2);
+      threads2.add_thread(th2);
+    }
+    threads2.join_all();
+  }
+  return boost::report_errors();
+}