mirror of
https://github.com/boostorg/thread.git
synced 2026-01-24 06:22:12 +00:00
8affa33718
* [@http://svn.boost.org/trac/boost/ticket/2309 #2309] Lack of g++ symbol visibility support in Boost.Thread. * [@http://svn.boost.org/trac/boost/ticket/2639 #2639] documentation should be extended(defer_lock, try_to_lock, ...). * [@http://svn.boost.org/trac/boost/ticket/3639 #3639] Boost.Thread doesn't build with Sun-5.9 on Linux. * [@http://svn.boost.org/trac/boost/ticket/3762 #3762] Thread can't be compiled with winscw (Codewarrior by Nokia). * [@http://svn.boost.org/trac/boost/ticket/3885 #3885] document about mix usage of boost.thread and native thread api. * [@http://svn.boost.org/trac/boost/ticket/3975 #3975] Incorrect precondition for promise::set_wait_callback(). * [@http://svn.boost.org/trac/boost/ticket/4048 #4048] thread::id formatting involves locale * [@http://svn.boost.org/trac/boost/ticket/4315 #4315] gcc 4.4 Warning: inline ... declared as dllimport: attribute ignored. * [@http://svn.boost.org/trac/boost/ticket/4480 #4480] OpenVMS patches for compiler issues workarounds. * [@http://svn.boost.org/trac/boost/ticket/4819 #4819] boost.thread's documentation misprints. * [@http://svn.boost.org/trac/boost/ticket/5423 #5423] thread issues with C++0x. * [@http://svn.boost.org/trac/boost/ticket/5617 #5617] boost::thread::id copy ctor. * [@http://svn.boost.org/trac/boost/ticket/5739 #5739] set-but-not-used warnings with gcc-4.6. * [@http://svn.boost.org/trac/boost/ticket/5826 #5826] threads.cpp: resource leak on threads creation failure. * [@http://svn.boost.org/trac/boost/ticket/5839 #5839] thread.cpp: ThreadProxy leaks on exceptions. * [@http://svn.boost.org/trac/boost/ticket/5859 #5859] win32 shared_mutex constructor leaks on exceptions. * [@http://svn.boost.org/trac/boost/ticket/6100 #6100] Compute hardware_concurrency() using get_nprocs() on GLIBC systems. * [@http://svn.boost.org/trac/boost/ticket/6168 #6168] recursive_mutex is using wrong config symbol (possible typo). * [@http://svn.boost.org/trac/boost/ticket/6175 #6175] Compile error with SunStudio. * [@http://svn.boost.org/trac/boost/ticket/6200 #6200] patch to have condition_variable and mutex error better handle EINTR. * [@http://svn.boost.org/trac/boost/ticket/6207 #6207] shared_lock swap compiler error on clang 3.0 c++11. * [@http://svn.boost.org/trac/boost/ticket/6208 #6208] try_lock_wrapper swap compiler error on clang 3.0 c++11. [SVN r76291]
269 lines
9.6 KiB
C++
269 lines
9.6 KiB
C++
// (C) Copyright 2006-7 Anthony Williams
|
|
// 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/test/unit_test.hpp>
|
|
#include <boost/thread/thread.hpp>
|
|
#include <boost/thread/xtime.hpp>
|
|
#include "util.inl"
|
|
#include "shared_mutex_locking_thread.hpp"
|
|
|
|
#define CHECK_LOCKED_VALUE_EQUAL(mutex_name,value,expected_value) \
|
|
{ \
|
|
boost::mutex::scoped_lock lock(mutex_name); \
|
|
BOOST_CHECK_EQUAL(value,expected_value); \
|
|
}
|
|
|
|
|
|
void test_timed_lock_shared_times_out_if_write_lock_held()
|
|
{
|
|
boost::shared_mutex rw_mutex;
|
|
boost::mutex finish_mutex;
|
|
boost::mutex unblocked_mutex;
|
|
unsigned unblocked_count=0;
|
|
boost::mutex::scoped_lock finish_lock(finish_mutex);
|
|
boost::thread writer(simple_writing_thread(rw_mutex,finish_mutex,unblocked_mutex,unblocked_count));
|
|
boost::thread::sleep(delay(1));
|
|
CHECK_LOCKED_VALUE_EQUAL(unblocked_mutex,unblocked_count,1u);
|
|
|
|
boost::system_time const start=boost::get_system_time();
|
|
boost::system_time const timeout=start+boost::posix_time::milliseconds(500);
|
|
boost::posix_time::milliseconds const timeout_resolution(50);
|
|
bool timed_lock_succeeded=rw_mutex.timed_lock_shared(timeout);
|
|
BOOST_CHECK((timeout-timeout_resolution)<boost::get_system_time());
|
|
BOOST_CHECK(!timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock_shared();
|
|
}
|
|
|
|
boost::posix_time::milliseconds const wait_duration(500);
|
|
boost::system_time const timeout2=boost::get_system_time()+wait_duration;
|
|
timed_lock_succeeded=rw_mutex.timed_lock_shared(wait_duration);
|
|
BOOST_CHECK((timeout2-timeout_resolution)<boost::get_system_time());
|
|
BOOST_CHECK(!timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock_shared();
|
|
}
|
|
|
|
finish_lock.unlock();
|
|
writer.join();
|
|
}
|
|
|
|
void test_timed_lock_shared_succeeds_if_no_lock_held()
|
|
{
|
|
boost::shared_mutex rw_mutex;
|
|
boost::mutex finish_mutex;
|
|
boost::mutex unblocked_mutex;
|
|
|
|
boost::system_time const start=boost::get_system_time();
|
|
boost::system_time const timeout=start+boost::posix_time::milliseconds(500);
|
|
boost::posix_time::milliseconds const timeout_resolution(50);
|
|
bool timed_lock_succeeded=rw_mutex.timed_lock_shared(timeout);
|
|
BOOST_CHECK(boost::get_system_time()<timeout);
|
|
BOOST_CHECK(timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock_shared();
|
|
}
|
|
|
|
boost::posix_time::milliseconds const wait_duration(500);
|
|
boost::system_time const timeout2=boost::get_system_time()+wait_duration;
|
|
timed_lock_succeeded=rw_mutex.timed_lock_shared(wait_duration);
|
|
BOOST_CHECK(boost::get_system_time()<timeout2);
|
|
BOOST_CHECK(timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock_shared();
|
|
}
|
|
|
|
}
|
|
|
|
void test_timed_lock_shared_succeeds_if_read_lock_held()
|
|
{
|
|
boost::shared_mutex rw_mutex;
|
|
boost::mutex finish_mutex;
|
|
boost::mutex unblocked_mutex;
|
|
unsigned unblocked_count=0;
|
|
boost::mutex::scoped_lock finish_lock(finish_mutex);
|
|
boost::thread reader(simple_reading_thread(rw_mutex,finish_mutex,unblocked_mutex,unblocked_count));
|
|
boost::thread::sleep(delay(1));
|
|
CHECK_LOCKED_VALUE_EQUAL(unblocked_mutex,unblocked_count,1u);
|
|
|
|
boost::system_time const start=boost::get_system_time();
|
|
boost::system_time const timeout=start+boost::posix_time::milliseconds(500);
|
|
boost::posix_time::milliseconds const timeout_resolution(50);
|
|
bool timed_lock_succeeded=rw_mutex.timed_lock_shared(timeout);
|
|
BOOST_CHECK(boost::get_system_time()<timeout);
|
|
BOOST_CHECK(timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock_shared();
|
|
}
|
|
|
|
boost::posix_time::milliseconds const wait_duration(500);
|
|
boost::system_time const timeout2=boost::get_system_time()+wait_duration;
|
|
timed_lock_succeeded=rw_mutex.timed_lock_shared(wait_duration);
|
|
BOOST_CHECK(boost::get_system_time()<timeout2);
|
|
BOOST_CHECK(timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock_shared();
|
|
}
|
|
|
|
finish_lock.unlock();
|
|
reader.join();
|
|
}
|
|
|
|
void test_timed_lock_times_out_if_write_lock_held()
|
|
{
|
|
boost::shared_mutex rw_mutex;
|
|
boost::mutex finish_mutex;
|
|
boost::mutex unblocked_mutex;
|
|
unsigned unblocked_count=0;
|
|
boost::mutex::scoped_lock finish_lock(finish_mutex);
|
|
boost::thread writer(simple_writing_thread(rw_mutex,finish_mutex,unblocked_mutex,unblocked_count));
|
|
boost::thread::sleep(delay(1));
|
|
CHECK_LOCKED_VALUE_EQUAL(unblocked_mutex,unblocked_count,1u);
|
|
|
|
boost::system_time const start=boost::get_system_time();
|
|
boost::system_time const timeout=start+boost::posix_time::milliseconds(500);
|
|
boost::posix_time::milliseconds const timeout_resolution(50);
|
|
bool timed_lock_succeeded=rw_mutex.timed_lock(timeout);
|
|
BOOST_CHECK((timeout-timeout_resolution)<boost::get_system_time());
|
|
BOOST_CHECK(!timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock();
|
|
}
|
|
|
|
boost::posix_time::milliseconds const wait_duration(500);
|
|
boost::system_time const timeout2=boost::get_system_time()+wait_duration;
|
|
timed_lock_succeeded=rw_mutex.timed_lock(wait_duration);
|
|
BOOST_CHECK((timeout2-timeout_resolution)<boost::get_system_time());
|
|
BOOST_CHECK(!timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock();
|
|
}
|
|
|
|
finish_lock.unlock();
|
|
writer.join();
|
|
}
|
|
|
|
void test_timed_lock_succeeds_if_no_lock_held()
|
|
{
|
|
boost::shared_mutex rw_mutex;
|
|
boost::mutex finish_mutex;
|
|
boost::mutex unblocked_mutex;
|
|
|
|
boost::system_time const start=boost::get_system_time();
|
|
boost::system_time const timeout=start+boost::posix_time::milliseconds(500);
|
|
boost::posix_time::milliseconds const timeout_resolution(50);
|
|
bool timed_lock_succeeded=rw_mutex.timed_lock(timeout);
|
|
BOOST_CHECK(boost::get_system_time()<timeout);
|
|
BOOST_CHECK(timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock();
|
|
}
|
|
|
|
boost::posix_time::milliseconds const wait_duration(500);
|
|
boost::system_time const timeout2=boost::get_system_time()+wait_duration;
|
|
timed_lock_succeeded=rw_mutex.timed_lock(wait_duration);
|
|
BOOST_CHECK(boost::get_system_time()<timeout2);
|
|
BOOST_CHECK(timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock();
|
|
}
|
|
|
|
}
|
|
|
|
void test_timed_lock_times_out_if_read_lock_held()
|
|
{
|
|
boost::shared_mutex rw_mutex;
|
|
boost::mutex finish_mutex;
|
|
boost::mutex unblocked_mutex;
|
|
unsigned unblocked_count=0;
|
|
boost::mutex::scoped_lock finish_lock(finish_mutex);
|
|
boost::thread reader(simple_reading_thread(rw_mutex,finish_mutex,unblocked_mutex,unblocked_count));
|
|
boost::thread::sleep(delay(1));
|
|
CHECK_LOCKED_VALUE_EQUAL(unblocked_mutex,unblocked_count,1u);
|
|
|
|
boost::system_time const start=boost::get_system_time();
|
|
boost::system_time const timeout=start+boost::posix_time::milliseconds(500);
|
|
boost::posix_time::milliseconds const timeout_resolution(50);
|
|
bool timed_lock_succeeded=rw_mutex.timed_lock(timeout);
|
|
BOOST_CHECK((timeout-timeout_resolution)<boost::get_system_time());
|
|
BOOST_CHECK(!timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock();
|
|
}
|
|
|
|
boost::posix_time::milliseconds const wait_duration(500);
|
|
boost::system_time const timeout2=boost::get_system_time()+wait_duration;
|
|
timed_lock_succeeded=rw_mutex.timed_lock(wait_duration);
|
|
BOOST_CHECK((timeout2-timeout_resolution)<boost::get_system_time());
|
|
BOOST_CHECK(!timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock();
|
|
}
|
|
|
|
finish_lock.unlock();
|
|
reader.join();
|
|
}
|
|
|
|
void test_timed_lock_times_out_but_read_lock_succeeds_if_read_lock_held()
|
|
{
|
|
boost::shared_mutex rw_mutex;
|
|
boost::mutex finish_mutex;
|
|
boost::mutex unblocked_mutex;
|
|
unsigned unblocked_count=0;
|
|
boost::mutex::scoped_lock finish_lock(finish_mutex);
|
|
boost::thread reader(simple_reading_thread(rw_mutex,finish_mutex,unblocked_mutex,unblocked_count));
|
|
boost::this_thread::sleep(boost::posix_time::seconds(1));
|
|
CHECK_LOCKED_VALUE_EQUAL(unblocked_mutex,unblocked_count,1u);
|
|
|
|
boost::system_time const start=boost::get_system_time();
|
|
boost::system_time const timeout=start+boost::posix_time::milliseconds(500);
|
|
bool timed_lock_succeeded=rw_mutex.timed_lock(timeout);
|
|
BOOST_CHECK(!timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock();
|
|
}
|
|
|
|
boost::posix_time::milliseconds const wait_duration(500);
|
|
timed_lock_succeeded=rw_mutex.timed_lock_shared(wait_duration);
|
|
BOOST_CHECK(timed_lock_succeeded);
|
|
if(timed_lock_succeeded)
|
|
{
|
|
rw_mutex.unlock_shared();
|
|
}
|
|
|
|
finish_lock.unlock();
|
|
reader.join();
|
|
}
|
|
|
|
|
|
boost::unit_test::test_suite* init_unit_test_suite(int, char*[])
|
|
{
|
|
boost::unit_test::test_suite* test =
|
|
BOOST_TEST_SUITE("Boost.Threads: shared_mutex test suite");
|
|
|
|
test->add(BOOST_TEST_CASE(&test_timed_lock_shared_times_out_if_write_lock_held));
|
|
test->add(BOOST_TEST_CASE(&test_timed_lock_shared_succeeds_if_no_lock_held));
|
|
test->add(BOOST_TEST_CASE(&test_timed_lock_shared_succeeds_if_read_lock_held));
|
|
test->add(BOOST_TEST_CASE(&test_timed_lock_times_out_if_write_lock_held));
|
|
test->add(BOOST_TEST_CASE(&test_timed_lock_times_out_if_read_lock_held));
|
|
test->add(BOOST_TEST_CASE(&test_timed_lock_succeeds_if_no_lock_held));
|
|
test->add(BOOST_TEST_CASE(&test_timed_lock_times_out_but_read_lock_succeeds_if_read_lock_held));
|
|
|
|
return test;
|
|
}
|