本文章介绍自己用过的多线程操作的知识点。用的都是boost库里的东西。
一、thread的创建
主要是需要创建一个通讯线程和任务线程。
void ThreadController::run(){
communicateThread=boost::thread(boost::bind(&ThreadController::m_communicate,this);
task=std::unique_ptr<TaskProduct>(TaskFactory::CreateTask("task"));
taskThread=boost::thread(boost::bind(&ThreadController::m_task,this));
communicateThread.join();
}
这里用到的有boost::thread(),boost::bind(),thread.join(),unique_ptr。对各个函数进行介绍。
1.1 boost::thread
创建boost::thread类型的变量分为不同的情况
void A(){};
thread t(A);
taskThread=boost::thread(boost::bind(&ThreadController::m_task,this));
需要利用boost::bind()函数。 boost::bind是标准库函数std::bind1st和std::bind2nd的一种泛化形式。其可以支持函数对象、函数、函数指针、成员函数指针,并且绑定任意参数到某个指定值上或者将输入参数传入任意位置。 对自由方法来说,直接boost::bind(函数名, 参数1,参数2,…) 对类方法来说,直接boost::bind(&类名::方法名,类实例指针,参数1,参数2)
1.2 thread.join();
该函数作用是暂停当前的线程,一直等到调用boost::thread::join()函数的线程运行结束,调用的函数的线程结束后,才继续进行后面的操作。
二、线程间的通信与同步
线程间的通讯主要利用全局变量来进行传递。 同步使用线程锁来进行。 用到的形式有atomic,unique_lock,shared_mutex,
boost::thread::atomic<type> Param::data;
{
boost::unique_lock<boost::shared_mutex> writelock(framelock);
buff.set(Param::data);
}
***
***
boost::this_thread::sleep(boost::posix_time::milliseconds(5));
2.1 atomic
如两个线程操作同一变量过程中,一个线程执行过程中可能被内核临时挂起,这就是线程切换,当内核再次切换到该线程时,之前的数据可能已被修改,不能保证原子操作。
2.2 shared_mutex与线程锁
- shared_mutex读写锁
读写锁。只能有一个线程写,或者多个线程同时读。 - 互斥锁、条件锁、自旋锁、读写锁、递归锁
2.3 unique_lock与lock_guard
lock_guard是为了防止线程死锁,而使用的一种 unique_lock是lock_guard的加强版,unique_lock提供了更多的接口,使其更加灵活,但性能方面也会有些受损。
|