Subject: [Boost-commit] svn:boost r83286 - trunk/libs/thread/test
From: vicente.botet_at_[hidden]
Date: 2013-03-03 14:13:58
Author: viboes
Date: 2013-03-03 14:13:58 EST (Sun, 03 Mar 2013)
New Revision: 83286
URL: http://svn.boost.org/trac/boost/changeset/83286
Log:
Thread: added test for #7755.
Added:
trunk/libs/thread/test/test_7755.cpp (contents, props changed)
Added: trunk/libs/thread/test/test_7755.cpp
==============================================================================
--- (empty file)
+++ trunk/libs/thread/test/test_7755.cpp 2013-03-03 14:13:58 EST (Sun, 03 Mar 2013)
@@ -0,0 +1,94 @@
+// Copyright (C) 2013 Vicente Botet
+//
+// 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)
+
+////////////////////////////////////////////
+
+//#define BOOST_THREAD_PROVIDES_GENERIC_SHARED_MUTEX_ON_WIN
+#include <iostream>
+#include <boost/thread/thread.hpp>
+#include <boost/thread/shared_mutex.hpp>
+// shared_mutex_deadlock.cpp : Defines the entry point for the console application.
+//
+
+
+boost::shared_mutex mutex;
+
+void thread2_func()
+{
+ int i (0);
+ while (true)
+ {
+ if (mutex.timed_lock(boost::posix_time::milliseconds(500)))
+ {
+ std::cout << "Unique lock acquired" << std::endl
+ << "Test successful" << std::endl;
+ mutex.unlock();
+ break;
+ }
+ ++i;
+ if (i == 100)
+ {
+ std::cout << "Test failed. App is deadlocked" << std::endl;
+ break;
+ }
+ boost::this_thread::sleep(boost::posix_time::seconds(1));
+ }
+}
+
+void thread3_func()
+{
+ boost::shared_lock<boost::shared_mutex> lock (mutex);
+ std::cout << "Shared lock acquired" << std::endl
+ << "Test successful" << std::endl;
+}
+
+void thread3_func_workaround()
+{
+ while (true)
+ {
+ if (mutex.timed_lock_shared(boost::posix_time::milliseconds(200)))
+ {
+ std::cout << "Shared lock acquired" << std::endl
+ << "Test successful" << std::endl;
+ mutex.unlock_shared();
+ break;
+ }
+ boost::this_thread::sleep(boost::posix_time::milliseconds(100));
+ }
+}
+
+int main()
+{
+ std::cout << "Starting" << std::endl;
+
+ // 1 - lock the mutex
+ boost::shared_lock<boost::shared_mutex> lock (mutex);
+
+ // 2 - start thread#2
+ boost::thread thread2(&thread2_func);
+
+ // 3 - sleep
+ boost::this_thread::sleep(boost::posix_time::milliseconds(10));
+
+ std::cout << "Thread#2 is waiting" << std::endl;
+
+ // - start thread3
+ boost::thread thread3(&thread3_func);
+ //boost::thread thread3(&thread3_func_workaround);
+
+ std::cout << "Thread#3 is started and blocked. It never will waked" << std::endl;
+
+ thread3.join(); // will never return
+
+ lock.unlock(); // release shared ownership. thread#2 will take unique ownership
+
+ thread2.join();
+
+ std::cout << "Finished" << std::endl;
+ return 0;
+}
+
+
+