posix thread封装

在看阅读RCF源码时，学习了一下posix thread在c++下的封装。

posix_thread.hpp

#include <boost/noncopyable.hpp>
#include <pthread.h>

//被pthread执行的线程入口
extern "c" {
  void* posix_thread_function(void*arg);
}

class posix_thread: private boost::noncopyable //禁止复制资源
{
public:
  template<typename Function>
  posix_thread(Function f):join_(false){
    start_thread(new func<Function>(f));
  }

  ~posix_thread();

  void join();
private:
  friend void* posix_thread_function(void*arg);//函数中访问类的私有类型、成员
  
  //提供纯虚接口，用以运行函数
  class func_base{
  public:
      virtual ~func_base(){} //需要提供一个{}
      virtual void run() = 0;
  };

  //将不同类型的函数封装统一接口
  //直接使用bind和function也可以实现这个功能
  template<typename Function>
  class func : public func_base {
  public:
  func(Function f):f_(f){}
  virtual void run() {
    f_();
  }
  private:
  Function f_;
  };

//使用RAII方式包装指针
  struct auto_func_base_ptr {
    ~auto_func_base_ptr(){
      delete p_;
    }
    func_base *p_;
  };
  void start_thread(func_base* f);

  bool join_;
  ::pthread_t thread_;
  }；

thread.cpp

posix_thread::~posix_thread() {
//如果对象管理的线程没有结束，自动detach，这样线程结束时，自动释放资源；
//在c++11中线程对象析构时joinable会导致抛出异常
  if (!join_)
    pthread_detach(thread_);
}

void posix_thread::join() {
  if (!join_) {
    ::pthread_join(thread_, 0);
    join_ = true;
  }
}

void posix_thread::start_thread(func_base* arg) {
  int err = pthread_create_pthread(&thread_, 0, posix_thread_function, arg);
  if (err != 0) {
    delete arg; //负责释放资源
    //抛出异常，create thread err
  }
}


void* posix_thread_function(void*arg) {
//友元函数
  posix_thread::auto_func_base_ptr func{
    static_cast<posix_thread::func_base*>(arg)
  };//struct 内数据成员为public，可以采用这种初始化方式
  func.p_->run();
  return 0;
}