boost信號量 boost::interprocess::interprocess_semaphore的用法

   使用方法首先給信號量初始化賦值,可以根據需要設定需要的值,之前在寫項目的過程中用這個控制下載的線程個數。

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

    然后就是pv操作了,v操作就只有一個post(),post()一次,信號量加1.p操作有三個,看函數名字都很明顯知道是什么意思,

 wait(),try_wait() ,timed_wait(const boost::posix_time::ptime&abs_time).

   這里需要注意的是第三個p操做,對boost也不太熟, 很明顯是等待到某一時間點,m_semaphore.timed_wait(boost::posix_time::ptime(second_clock::universal_time()+boost::posix_time::seconds(1))),等待一秒;這個時間是取universal_time,一開始不知道，試了幾次不行，后面靈機一動看了下源碼，原來如此.

inline bool interprocess_semaphore::timed_wait(const boost::posix_time::ptime &abs_time)
{
   if(abs_time == boost::posix_time::pos_infin){
      this->wait();
      return true;
   }
   //Obtain current count and target time
   boost::posix_time::ptime now(microsec_clock::universal_time());
   if(now >= abs_time)
      return false;

   do{
      if(this->try_wait()){
         break;
      }
      now = microsec_clock::universal_time();

      if(now >= abs_time){
         return this->try_wait();
      }
      // relinquish current time slice
      detail::thread_yield();
   }while (true);
   return true;
}

 下面舉個栗子

#include <boost/interprocess/sync/interprocess_semaphore.hpp>
#include <boost/thread.hpp>
#include <boost/bind.hpp>
#include <boost/date_time/posix_time/posix_time.hpp> 
#include <iostream>
using namespace std;
boost::interprocess::interprocess_semaphore m_semaphore(1);
void test(int i)
{
    while(true)
    {
        if(m_semaphore.try_wait())
        {
            printf("%d\n",i);
            m_semaphore.post();
            
        }
        boost::this_thread::sleep(boost::posix_time::seconds(2));

    }
}
using namespace boost::posix_time;
int main()
{
    boost::thread thread1(boost::bind(&test,1));
    boost::thread thread2(boost::bind(&test,2));
    getchar();

}