1 boost::interprocess::interprocess_semaphore m_semaphore(0);

 1 inline bool interprocess_semaphore::timed_wait(const boost::posix_time::ptime &abs_time)
 2 {
 3    if(abs_time == boost::posix_time::pos_infin){
 4       this->wait();
 5       return true;
 6    }
 7    //Obtain current count and target time
 8    boost::posix_time::ptime now(microsec_clock::universal_time());
 9    if(now >= abs_time)
10       return false;
11
12    do{
13       if(this->try_wait()){
14          break;
15       }
16       now = microsec_clock::universal_time();
17
18       if(now >= abs_time){
19          return this->try_wait();
20       }
21       // relinquish current time slice
22       detail::thread_yield();
23    }while (true);
24    return true;
25 }

 1 #include <boost/interprocess/sync/interprocess_semaphore.hpp>
 2 #include <boost/thread.hpp>
 3 #include <boost/bind.hpp>
 4 #include <boost/date_time/posix_time/posix_time.hpp>
 5 #include <iostream>
 6 using namespace std;
 7 boost::interprocess::interprocess_semaphore m_semaphore(1);
 8 void test(int i)
 9 {
10     while(true)
11     {
12         if(m_semaphore.try_wait())
13         {
14             printf("%d\n",i);
15             m_semaphore.post();
16
17         }
18         boost::this_thread::sleep(boost::posix_time::seconds(2));
19
20     }
21 }
22 using namespace boost::posix_time;
23 int main()
24 {
25     boost::thread thread1(boost::bind(&test,1));
26     boost::thread thread2(boost::bind(&test,2));
27     getchar();
28
29 }