码迷,mamicode.com
首页 > 编程语言 > 详细

(十)boost库之多线程

时间:2016-05-31 09:04:40      阅读:233      评论:0      收藏:0      [点我收藏+]

标签:

(十)boost库之多线程

1、创建线程

使用boost库可以方便的创建一个线程,并提供最多支持9个参数的线程函数,相对于void*来说,方便了很多,创建线程主要提供了一下3种方式:

线程库头文件:#include <boost/thread.hpp>

a、使用全局函数作为线程执行体

void Func(int nCount)
{
    for (int i = 0; i < nCount; i++)
    {
        cout <<  __FUNCTION__ << i << endl;
    }
}
int _tmain(int argc, _TCHAR* argv[])
{
    boost::thread th(Func, 100);
    //等待线程结束
    th.join();
}

 

b、使用成员函数作为线程执行体

class A
{
public:
    void Func(int nCount)
    {
        for (int i = 0; i < nCount; i++)
        {
            cout <<  __FUNCTION__ << i << endl;
        }
    }
};
//线程参数都采用值传递,因此即使如下传入一个临时变量作为参数,线程照样可以正确运行
//如果需要传递引用,可通过ref库来实现
boost::thread *pth;
void TestThread()
{
    A a;
    //线程绑定一个局部变量
    pth = new boost::thread( &A::Func, &a, 100);
}

 

c、仿函数作为线程执行体

class  B
{
public:
    B(int n):nMem(n)
    {
    }
    void operator()()
    {
        for (int i = 0; i < nMem; i++)
        {
            cout <<  __FUNCTION__ << i << endl;
        }
    }
    int nMem;
};
//线程thread对象销毁时,会与线程执行体分离,线程执行体不受影响
void TestThread2()
{
    //创建临时线程对象
    boost::thread(B(100));
}

 

结合以上方法,我们可以轻而易举的就创建一个线程,结合boost.bind库和lambda表达式,将会更方便。如:

boost::thread th3([](int nCount){
        for (int i = 0; i < nCount; i++)
        {
            cout <<  __FUNCTION__ << i << endl;
        }
    }, 10);

2、中断线程

线程不是在任意时刻都可以被中断,因此要实现中断,需要我们自己决定什么时候可以被中断,boost库定义了以下函数是可以被中断的:

  • boost::thread::join()
  • boost::thread::timed_join()
  • boost::boost::thread::try_join_for(),
  • boost::boost::thread::try_join_until(),
  • boost::condition_variable::wait()
  • boost::condition_variable::timed_wait()
  • boost::condition_variable::wait_for()
  • boost::condition_variable::wait_until()
  • boost::condition_variable_any::wait()
  • boost::condition_variable_any::timed_wait()
  • boost::condition_variable_any::wait_for()
  • boost::condition_variable_any::wait_until()
  • boost::thread::sleep()
  • boost::this_thread::sleep_for()
  • boost::this_thread::sleep_until()
  • boost::this_thread::interruption_point()

成员函数interrupt,运行正在执行的线程中断,被中断的线程会抛出异常类boost::thread_interrupted,程序应该自行处理该异常,以确保线程正确结束。

void interrupt_thread(int nCount)
{
    try
    {
        for (int i = 0; i < nCount; i++)
        {
            //sleep函数允许中断
            boost::this_thread::sleep(boost::posix_time::seconds(1));
            cout <<  __FUNCTION__ << i << endl;
        }
    }
    catch(boost::thread_interrupted&)
    {
        cout << "thread interrupt" << endl;
    }
}

boost::thread th2(interrupt_thread, 100);
boost::this_thread::sleep(boost::posix_time::seconds(4));
th2.interrupt();

在以上中断函数中,除了最后一个,其它都是等待函数,如果想在非等待情况下,运行线程被中断,就可以使用最后一个函数。

比如我们可以将上面的boost::this_thread::sleep(boost::posix_time::seconds(1));替换成  boost::this_thread::interruption_point();

 

3、线程组

有时我们需要管理一组线程对象,进行统一的等待处理,使用boost::thread_group可以轻松的处理。

#include <boost/bind.hpp>
void ThreadGroup()
{
    boost::thread_group grp;
    grp.create_thread( boost::bind(Func, 10));
    A a;
    grp.add_thread(new boost::thread(&A::Func, &a, 100));
    grp.add_thread(new boost::thread(B(100)));
    grp.join_all();
}

(十)boost库之多线程

标签:

原文地址:http://www.cnblogs.com/destim/p/5544679.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!