文章目录
- 创建线程
- 传递参数
- 等待线程完成
- 分离线程
- joinable()
创建线程
要创建线程,我们需要一个可调用的函数或函数对象,作为线程的入口点。在C++11中,我们可以使用函数指针、函数对象或lambda表达式来实现。
创建线程的基本语法如下:
#include
//头文件 using namespace std; thread t(function_name, args...); `function_name`是线程入口点的函数或可调用对象 `args...`是传递给函数的参数 创建线程后,我们可以使用t.join()等待线程完成,或者使用t.detach()分离线程,让它在后台运行。
#include
#include using namespace std; void print_message() { cout << "Hello, world!" << endl; } int main() { std::thread t(print_message); t.join(); return 0; } 我们定义了一个名为print_message的函数,它输出一条消息。
然后,我们创建了一个名为t的线程,将print_message函数作为入口点。
最后,我们使用t.join()等待线程完成。
传递参数
我们可以使用多种方式向线程传递参数,例如使用函数参数、全局变量、引用等。如:
#include
#include using namespace std; void print_message(const string& message) { cout << message << endl; } void increment(int& x) { ++x; } int main() { string message = "Hello, world!"; thread t(print_message, message); t.join(); int x = 0; thread t2(increment, ref(x)); t2.join(); cout << x << endl; return 0; } 在第一个例子中,我们使用了一个字符串作为函数参数,传递给线程。
在第二个例子中,我们使用了一个引用来传递一个整数变量。
需要注意的是,当我们使用引用传递参数时,我们需要使用std::ref来包装引用,否则编译器会报错。
等待线程完成
当我们创建一个线程后,我们可能需要等待它完成,以便获取线程的执行结果或执行清理操作。我们可以使用t.join()方法来等待线程完成。
例如,下面的代码创建了两个线程,等待它们完成后输出一条消息:
#include
#include using namespace std; void print_message(const std::string& message) { std::cout << message << std::endl; } int main() { thread t1(print_message, "Thread 1"); thread t2(print_message, "Thread 2"); t1.join(); t2.join(); cout << "All threads finished!" << endl; return 0; } 在这个例子中,我们创建了两个线程t1和t2,它们都调用print_message函数输出一条消息。
然后,我们使用t1.join()和t2.join()等待它们完成。最后,我们输出一条消息,表示所有线程都已经完成。
分离线程
有时候我们可能不需要等待线程完成,而是希望它在后台运行。
这时候我们可以使用t.detach()方法来分离线程。
例如,下面的代码创建了一个线程,分离它后输出一条消息:
#include
#include using namespace std; void print_message(const std::string& message) { cout << message << endl; } int main() { thread t(print_message, "Thread 1"); t.detach(); cout << "Thread detached" << endl; return 0; } 在这个例子中,我们创建了一个名为t的线程,调用print_message函数输出一条消息。
然后,我们使用t.detach()方法分离线程,让它在后台运行。
最后,我们输出一条消息,表示线程已经被分离。
需要注意的是,一旦线程被分离,就不能再使用t.join()方法等待它完成。
而且,我们需要确保线程不会在主线程结束前退出,否则可能会导致未定义行为。
joinable()
joinable()方法返回一个布尔值,如果线程可以被join()或detach(),则返回true,否则返回false。
如果我们试图对一个不可加入的线程调用join()或detach(),则会抛出一个std::system_error异常。
下面是一个使用joinable()方法的例子:
#include
#include using namespace std; void foo() { cout << "Thread started" << endl; } int main() { thread t(foo); if (t.joinable()) { t.join(); } cout << "Thread joined" << endl; return 0; } 本文是作为自己的一个学习记录,学习的资源来源于链接