前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >C++ std::thread线程详解

C++ std::thread线程详解

作者头像
艰默
发布2023-10-31 19:16:34
1.6K0
发布2023-10-31 19:16:34
举报
文章被收录于专栏:iDoitnow

1. thread是什么

多线程是一种功能,它允许并发执行程序的两个或多个部分,以最大限度地利用 CPU。这种程序的每个部分都称为线程。因此,线程是进程中的轻量级进程。多线程支持是在 C++11 中引入的。在 C++11 之前,我们必须使用 POSIX 线程或库。虽然这个库完成了这项工作,但缺乏任何标准语言提供的功能集导致了严重的可移植性问题。C++ 11 取消了所有这些,并给了我们 std::thread。线程类和相关函数在头文件<thread>中定义。

thread表示单个执行线程。线程在构建关联的线程对象时立即开始执行。其定义用于观察和管理应用程序中的执行线程的对象。

2. 创建一个thread

std::thread 是 C++ 中表示单个线程的线程类。要启动线程,我们只需要创建一个新的线程对象,并将要调用的执行代码(即可调用对象)传递到对象的构造函数中。

代码语言:javascript
复制
//当程序到达此行时,将在后台启动任务以运行aFunction 
//t:线程对象
//aFunction: 任务或线程执行
std::thread t(aFunction);

创建对象后,将启动一个新线程,该线程将执行 aFunction 中指定的代码。可调用对象可以是以下五个项中的任何一个:

  • 函数指针
  • Lambda 表达式
  • 函数对象
  • 非静态成员函数
  • 静态成员函数

定义可调用对象后,我们将其传递给构造函数。我们看以下例子:

代码语言:javascript
复制
/*****************1.使用函数指针启动线程********************/

//函数指针可以是可调用对象,传递给 std::thread 构造函数以初始化线程。
void foo(param)
{ 
   ... 
}
// The parameters to the function are put after the comma
std::thread thread_obj(foo, params);
/********************************************************/


/***************2.使用 Lambda 表达式启动线程****************/

//定义一个lambda表达式
auto f = [](params)
{
 ...
};

//使用 lambda 表达式作为可调用对象来启动
std::thread thread_object(f, params);
/********************************************************/


/******************3.使用函数对象启动线程*******************/

// 定义一个函数对象
class fn_object_class {
 // 重载operator()
 void operator()(params)
 { 
    ...
 }
}

std::thread thread_object(fn_object_class(), params);
/********************************************************/


/***************4.使用非静态成员函数启动线程****************/

// 定义一个类
class Base {
public:
 // 非静态成员函数
 void foo(param) { ... }
}

//创建Base类对象b
Base b;

// 第一个参数是类非静态成员函数的引用
// 第二个参数类对象的引用
// 第三个参数是非静态成员函数的参数
std::thread thread_obj(&Base::foo, &b, params);
/********************************************************/


/***************5.使用静态成员函数启动线程****************/

// 定义一个类
class Base {
public:
 //静态成员数
 static void foo(param) { ... }
}

//创建Base类对象b
Base b;
// 其一个参数是类静态成员函数的引用
// 第二个参数是该函数的参数
std::thread thread_obj(&Base::foo, params);
/********************************************************/

:我们总是将可调用对象的参数作为参数单独传递给线程构造函数。

3. 等待线程执行完毕

线程启动后,我们可能需要等待线程完成,然后才能采取一些操作。要等待线程,请使用 std::thread::join() 函数。此函数使当前线程等待,直到*this标识的线程完成执行。

代码语言:javascript
复制
int main()
{
 //开始一个线程t1
 std::thread t1(callable);

 //等待线程t1执行完成
 t1.join();

 //t1完成后再继续执行其他语句
 ...
}

有时我们需要知道线程对象是否可连接,即它与活动任务相关联。我们可以通过函数对其进行 joinable() 评估:

代码语言:javascript
复制
if (t.joinable())
    t.join();

其主要是检查 std::thread 对象是否标识活跃的执行线程。具体而言,若 get_id() != std::thread::id() 则返回true。故默认构造的 thread 不可结合。

std::thread::get_id返回线程的 id,即返回标识与 *this 关联的线程的std::thread::id

如果线程是 joinable ,并不意味着它已完成。它可能仍在运行。因此,如果我们调用 join() 一个 joinable 任务,它只有在它已经完成时才加入,否则,程序会等待它完成,然后加入。

4. 线程任务的移动和交换

没有两个 std::thread 对象会表示同一执行线程,因为 std::thread可移动构造可移动赋值,但不是可复制构造可复制赋值的。例如:

代码语言:javascript
复制
auto task(){/* 某些计算过程 */}
std::thread t1(task);
std::thread t2 = t1; //错误: 线程不可以复制
std::thread t3{t1}; // 错误: 线程不可以拷贝构造

//一次只有一个线程对象负责一个任务。但是,与线程对象关联的任务是可移动的:
std::thread t4 = std::move(t1); //正确: t4现在运行task,t1变成一个空对象

std::thread::swap成员函数可以交换两个 thread 对象,其实就是交换二个 thread 对象的底层柄。其函数原型如下:

代码语言:javascript
复制
void swap( std::thread& other ) noexcept; //C++11 起

除了可以使用成员函数外,也可以使用非成员数std::swap(std::thread) 来完成两个线程对象的交换。

代码语言:javascript
复制
void foo(){ ... }
void bar(){ ... }
std::thread t1(foo);
std::thread t2(bar);

//交换t1和t2
std::swap(t1, t2); //等效于t1.swap(t2);

5. 线程对象与任务分离

线程对象可以与其任务分离。这对于需要在后台运行的任务非常有用,我们不需要在运行时停止它。

std::thread::detach容许线程从线程句柄独立开来执行,其从 thread 对象分离执行线程,允许执行独立地持续。一旦该线程退出,则释放任何分配的资源。调用 detach*this不再占有任何线程。

示例:

代码语言:javascript
复制
#include <iostream>
#include <chrono>
#include <thread>
 
void independentThread() 
{
    std::cout << "Starting concurrent thread.\n";
    std::this_thread::sleep_for(std::chrono::seconds(2));
    std::cout << "Exiting concurrent thread.\n";
}
 
void threadCaller() 
{
    std::cout << "Starting thread caller.\n";
    std::thread t(independentThread);
    t.detach();
    std::this_thread::sleep_for(std::chrono::seconds(1));
    std::cout << "Exiting thread caller.\n";
}
 
int main() 
{
    threadCaller();
    std::this_thread::sleep_for(std::chrono::seconds(5));
}

可能的输出:

代码语言:javascript
复制
Starting thread caller.
Starting concurrent thread.
Exiting thread caller.
Exiting concurrent thread.
本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2023-10-29,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 iDoitnow 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 1. thread是什么
  • 2. 创建一个thread
  • 3. 等待线程执行完毕
  • 4. 线程任务的移动和交换
  • 5. 线程对象与任务分离
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档