diff options
Diffstat (limited to 'src/boost/libs/thread/test/test_7755.cpp')
-rw-r--r-- | src/boost/libs/thread/test/test_7755.cpp | 94 |
1 files changed, 94 insertions, 0 deletions
diff --git a/src/boost/libs/thread/test/test_7755.cpp b/src/boost/libs/thread/test/test_7755.cpp new file mode 100644 index 000000000..5551a6bb9 --- /dev/null +++ b/src/boost/libs/thread/test/test_7755.cpp @@ -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_only.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); + for (;;) + { + 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() +{ + for (;;) + { + 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; +} + + + |