您的位置：首页 > 其它

（十）boost库之多线程

2016-05-31 08:29 381 查看

（十）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();

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航