C++ boost thread学习(一)

 

线程中断 

在一个线程对象上调用 interrupt() 会中断相应的线程，并会在这个线程中抛出一个类型为 boost::thread_interrupted 的异常。 

如果给定的线程不包含任何中断点，简单调用interrupt就不会起作用。 每当一个线程中断点，它就会检查interrupt是否被调用过。只有被调用过了， boost::thread_interrupted 异常才会相应地抛出。 

Boost.Thread定义了一系列的中断点，例如sleep() 函数，由于sleep() 在这个例子里被调用了五次，该线程就检查了五次它是否应该被中断。然而sleep()之间的调用，却不能使线程中断。 

一旦该程序被执行，它只会打印三个标准输出流。这是由于在main里3秒后调用 interrupt()方法。 因此，相应的线程被中断，并抛出一个 boost::thread_interrupted 异常。这个异常在线程内也被正确地捕获，catch 处理是空的。

Boost.Thread定义包括上述 sleep()函数等十个中断。 有了这些中断点，线程可以很容易及时中断。然而，他们并不总是最佳的选择，因为中断点必须事前读入以检查 boost::thread_interrupted 异常。 

#include <boost/thread.hpp>
#include <boost/thread/mutex.hpp>

#include <iostream>

boost::mutex io_mutex;

using namespace std;

void wait(int seconds)
{
boost::this_thread::sleep(boost::posix_time::seconds(seconds));
}

void interruptedThread()
{
    try
    {
        for (int i = 0; i < 5; i++)
        {
            wait(1);
            cout << i << endl;
        }
    }
    catch (boost::thread_interrupted&)
    {
        cout << "thread_interrupted exception happened";
    }
}

void testInteruptedThread()
{
    boost::thread t(interruptedThread);
    wait(3);
    t.interrupt();
    t.join();
}

int main(int argc, char* argv[])
{
    testInteruptedThread();
    return 0;
}