ceph/src/boost/libs/thread/test/test_4648.cpp

   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);
  18   boostThreadLocksTest()
  19     :myMutex()
  20      //, myLock(myMutex,boost::defer_lock_t())
  21   {}
  22 };
  23
  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 }
  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 }
  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 }