目的
本例简介c++11中thread库如何创建与停止线程。
实现
如下的实例中,通过ThreadWrapper::start()方法启动线程,通过ThreadWrapper::stop()方法停止线程。线程的主体函数为Thread::run()方法。
#include <iostream>
#include <thread>
#include <memory>
#include <unistd.h>
class ThreadWrapper {
private:
std::unique_ptr<std::thread> thread_;
volatile bool isRun = false;
public:
void run() {
std::cout << "Thread start\n";
while (isRun)
sleep(1);
std::cout << "Thread stop\n";
}
void start() {
isRun = true;
thread_.reset(new std::thread([&]() {
run();
}));
}
void stop() {
isRun = false;
thread_->join();
thread_.reset();
}
};
int main() {
ThreadWrapper tw;
tw.start();
getchar();
tw.stop();
return 0;
}
启动
在std::thread()对象创建成功后,线程的主方法就会自动在新创建的线程环境中运行。本例使用lambda表达式将线程的主体函数指向类的成员函数run()。
停止
基本上你应该对所有创建的线程考虑它的退出方法,否则会导致内存泄漏等问题。线程的停止方式有很多,不过我只推荐你用上述的join()方法。
- std::thread::join()方法会等待线程运行结束后返回,并可以传递返回结果。
- std::thread::detach()方法也可以作为一种退出方法:它告诉操作系统在线程结束运行后,自动回收线程所占用的资源。因此你可以在创建线程后的任何时机调用它,而不需要等到需要退出之前。
- 还有很多其他的线程退出方法,如pthread_cancel()等,不过非常不推荐使用,因为很容易造成资源泄露。
总结
- 本文给出一种相对容易以及资源安全的线程创建/退出方法。
- 使用lambda表达式会简化线程在类中的创建。
- 本文所介绍的线程的创建/退出方法不仅适用于c++,可以在java,python等其他语言中使用。
引用
[1] https://en.cppreference.com/w/cpp/thread/thread/detach
[2] http://www.cplusplus.com/reference/thread/thread/join/