1 // Copyright (C) 2010 Vicente Botet
2 //
3 // Distributed under the Boost Software License, Version 1.0. (See accompanying
4 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
5
6 #include <iostream>
7 #include <boost/thread.hpp>
8 #include <boost/current_function.hpp>
9
10 class boostThreadLocksTest
11 {
12 public:
13 boost::shared_mutex myMutex;
14 //boost::upgrade_lock<boost::shared_mutex> myLock;
15 static int firstFunction(boostThreadLocksTest *pBoostThreadLocksTest);
16 static int secondFunction(boostThreadLocksTest *pBoostThreadLocksTest,
17 boost::upgrade_lock<boost::shared_mutex>& upgr);
boostThreadLocksTest()18 boostThreadLocksTest()
19 :myMutex()
20 //, myLock(myMutex,boost::defer_lock_t())
21 {}
22 };
23
firstFunction(boostThreadLocksTest * pBoostThreadLocksTest)24 int boostThreadLocksTest::firstFunction(boostThreadLocksTest *pBoostThreadLocksTest)
25 {
26 std::cout<<"Entering "<<boost::this_thread::get_id()<<" "<<"firstFunction"<<std::endl;
27 boost::upgrade_lock<boost::shared_mutex> myLock(pBoostThreadLocksTest->myMutex);
28 pBoostThreadLocksTest->secondFunction(pBoostThreadLocksTest, myLock);
29 std::cout<<"Returned From Call "<<boost::this_thread::get_id()<<" "<<"firstFunction"<<std::endl;
30 std::cout<<"Returning from "<<boost::this_thread::get_id()<<" "<<"firstFunction"<<std::endl;
31 return(0);
32 }
secondFunction(boostThreadLocksTest *,boost::upgrade_lock<boost::shared_mutex> & upgr)33 int boostThreadLocksTest::secondFunction(boostThreadLocksTest *, boost::upgrade_lock<boost::shared_mutex>& upgr) {
34 std::cout<<"Before Exclusive Locking "<<boost::this_thread::get_id()<<" "<<"secondFunction"<<std::endl;
35 boost::upgrade_to_unique_lock<boost::shared_mutex> localUniqueLock(upgr);
36 std::cout<<"After Exclusive Locking "<<boost::this_thread::get_id()<<" "<<"secondFunction"<<std::endl;
37 return(0);
38 }
main()39 int main() {
40 boostThreadLocksTest myObject;
41 boost::thread_group myThreadGroup;
42 myThreadGroup.create_thread(boost::bind(boostThreadLocksTest::firstFunction,&myObject));
43 myThreadGroup.create_thread(boost::bind(boostThreadLocksTest::firstFunction,&myObject));
44 myThreadGroup.create_thread(boost::bind(boostThreadLocksTest::firstFunction,&myObject));
45 myThreadGroup.join_all();
46 return 0;
47 }
48