首页 > 编程语言 >《C++并发编程实战》读书笔记(1):线程管控

《C++并发编程实战》读书笔记(1):线程管控

时间:2023-09-02 10:55:57浏览次数:43  
标签:std 函数 thread 读书笔记 void C++ 线程 data

1、线程的基本管控

包含头文件<thread>后,通过构建std::thread对象启动线程,任何可调用类型都适用于std::thread

void do_some_work();

struct BackgroundTask
{
    void operator()() const;
};

//空的thread对象,不接管任何线程函数
std::thread t1;

//传入普通函数
std::thread t2(do_some_work);

//传入lambda函数
std::thread t3([]() { /*do something*/ });

//传入可调用对象
BackgroundTask task;
std::thread t4(task);
//不能使用std::thread t4(BackgroundTask()),虽然本意是传入临时变量,但这会被编译器解释成函数声明。多用一对圆括号或者使用列表初始化可以解决这个问题。
std::thread t5((BackgroundTask()));
std::thread t6{BackgroundTask()};

启动线程后,需要明确是等待它结束、还是任由它独自运行:

  • 调用成员函数join()会先等待线程结束,然后隶属于该线程的任何存储空间都会被清除,std::thread对象不再关联到已结束的线程。
  • 调用成员函数detach()会分离线程使其在后台运行,此后无法获得与它关联的std::thread对象。分离线程的归属权和控制权都转移给了C++运行时库,线程退出时与之关联的资源会被正确回收。

调用了join()或是detach()之后,其joinable()方法将返回false,所以也就不能再调用join()。不能对空的std::thread对象调用join()或是detach()。如果线程启动后既不调用join()也不调用detach(),那么当std::thread对象销毁时,其析构函数将调用std::terminate()终止整个程序。

2、向线程函数传递参数

若需向线程上的函数传递参数,直接向std::thread的构造函数添加更多参数即可。线程具有内部存储空间,参数会按照默认方式先复制到该处,然后这些副本被当作临时变量,以右值形式传递给线程上的函数。即使函数的相关参数按设想应该是引用,上述过程依然会发生。

void f(int i, const std::string& s);
std::thread t(f, 3, "hello");

上述代码在新线程上调用f(3, "hello"),尽管f()的第二个参数是std::string类型,但字符串内容仍然以指针const char*的形式传入,直到进入新线程的上下文环境后才转换为std::string类型。所以如果参数是指针,需要特别注意其生命周期,否则可能导致严重问题,例如:

void f(int i, const std::string& s);

void oops(int param)
{
    char buffer[1024];
    sprintf(buffer, "%d", param);
    std::thread t(f, 3, buffer);
    t.detach();
}

buffer是指向局部数组的指针,我们原本设想buffer会在新线程内转换成std::string对象,但在此完成之前,oops()函数很有可能已经退出,导致局部数组被销毁从而引发未定义的行为。这一问题的根源在于:std::thread的构造函数原样复制所提供的值,并未立即将其转换成预期的参数类型,等到转换发生时,指针可能已经失效。所以解决方法就是,在buffer传入std::thread的构造函数之前,就先把它转换成std::string对象:

std::thread t(f, 3, std::string(buffer));

除了指针外,传递引用也需要小心。例如我们想要的是非const引用:

void update_widget_data(WidgetData& data);

void oops()
{
    WidgetData data;
    std::thread t(update_widget_data, data);
    t.join();
}

根据update_widget_data函数的声明,参数需要以引用的方式传入,但std::thread的构造函数对此却毫不知情,它忽略了函数所期望的参数类型,直接复制了我们提供的值。然而,线程库的内部代码会把参数的副本(std::thread构造时由对象data复制得出,位于新线程的内部存储空间)以右值的形式传递给update_widget_data函数,所以这段代码会编译失败,因为不能向非const引用传递右值。解决方法就是使用std::ref()函数加以包装,这样传递给update_widget_data函数的就是指向data的引用,代码就能编译成功:

std::thread t(update_widget_data, std::ref(data));

要将某个类的成员函数设为线程函数,我们需要给出合适的对象指针作为第一个参数,成员函数的参数放在其后的位置。

class X
{
public:
    void do_lengthy_work();
}

X my_x;
std:thread t(&X::do_lengthy_work, &my_x);

对于只能移动、不能复制的对象,传递参数时需要使用std::move()来转移归属权。在下面的例子中,BigObject对象的归属权会发生转移,先进入新创建的线程的内部存储空间,再转移给process_big_object()函数。

void process_big_object(std::unique_ptr<BigObject>);

std::unique_ptr<BigObject> p(new BigObject);
std::thread t(process_big_object, std::move(p));

3、移交线程归属权

std::thread不能复制,但支持移动语义。对于一个具体的执行线程,其归属权可以在多个std::thread实例之间转移。

void some_function();

void some_other_function();

std::thread t1(some_function);
std::thread t2 = std::move(t1); //将线程的归属权显式地转移给t2
t1 = std::thread(some_other_function); //线程原本与std::thread临时对象关联,其归属权随即转移给t1
std::thread t3; //按默认方式构造,未关联任何线程
t3 = std::move(t2); //t2原本关联的线程的归属权转移给t3
//经过上面这些转移,t1与运行some_other_function的线程关联,t2没有关联线程,t3与运行some_function的线程关联

t1 = std::move(t3); //在这次转移之时,t1已经关联运行some_other_function的线程,因此std::thread的析构函数中会调用std::terminate(),终止整个程序。所以只要std::thread对象还在管控着一个线程,就不能简单地向它赋新值。

因为std::thread支持移动语义,所以只要容器同样知悉移动意图,就可以装载std::thread对象。因此我们可以写出下列代码,生成多个线程,然后等待它们运行完成。

void do_work(unsigned id);

void foo()
{
    std::vector<std::thread> threads;
    for (unsigned i = 0; i < 20; ++i)
    {
        threads.push_back(std::thread(do_work, i));
    }
    for (auto& entry : threads)
    {
        entry.join();
    }
}

4、识别线程

使用C++标准库的std::thread::hardware_concurrency()函数可以获取系统中逻辑处理器的数量。如果信息无法获取,该函数可能返回0。

线程ID的类型是std::thread::id,它有两种获取方法:

  • 在与线程关联的std::thread对象上调用成员函数get_id(),即可得到该线程的ID。如果std::thread对象没有关联任何执行线程,则调用get_id()返回的是按默认构造方式生成的std::thread::id对象,表示“线程不存在”。
  • 当前线程的ID可以通过调用std::this_thread::get_id()获取。

std::thread::id对象可以支持很多种操作:

  • 可随意进行复制操作或比较运算。
  • 可用作关联容器(std::setstd::mapstd::multisetstd::multimap)的键值,无序关联容器(std::unordered_setstd::unordered_mapstd::unordered_multisetstd::unordered_multimap)的键值,或用于排序。
  • 写到输出流,例如std::cout << std::this_thread::get_id();

标签:std,函数,thread,读书笔记,void,C++,线程,data
From: https://www.cnblogs.com/moonzzz/p/17668338.html

相关文章

  • Redis队列Stream&Redis多线程详解(8)
    Redis目前最新版本为Redis-6.2.6,考虑到实际的情况,本次课程会以CentOS7下Redis-6.2.4版本进行讲解。下载地址:https://redis.io/download安装运行Redis很简单,在Linux下执行上面的4条命令即可,同时前面的课程已经有完整的视频讲解,请到网盘中下载观看,并自行安装。如安装过程出......
  • C++中基类和派生类的析构函数
    和构造函数类似,析构函数也不能被继承。与构造函数不同的是,在派生类的析构函数中不用显式地调用基类的析构函数,因为每个类只有一个析构函数,编译器知道如何选择,无需程序员干涉。另外析构函数的执行顺序和构造函数的执行顺序也刚好相反:创建派生类对象时,构造函数的执行顺序和继承顺序相......
  • C++一阶--通讯录管理系统
    照着黑马程序员C++视频敲的,可以快速回忆起当时上课学的东西。其实当时期末的那个设计我也是敲得这个”通讯录管理系统“,这算是我大学以及编程的第一个成就。再次完成亦有感慨。先说我我想说的:体会了结构体增删改查的实现冒泡排序指针中”&“与”*“的区别函数封装的妙处......
  • C++智能指针
    一、常规指针的缺点当一个常规指针离开了作用域时,只有该指针变量本身占用的内存空间(4/8字节)会被释放,而它指向的内存空间不会自动释放,当free\delete\delete[]语句忘记执行或者无法执行,形成内存泄漏二、智能指针的优点智能指针是一个封装了常规指针的类类型对象,并且重载了......
  • C++异常处理
    一、异常处理程序的错误大致分三种:语法错误、逻辑错误、运行时错误运行时错误发生在程序运行期间发生的问题:除零、内存分配失败、非法访问内存、文件不存在、数组越界C++的异常处理机制就是为了解决运行时错误C语言中运行时错误如果不管,系统会执行默认操作,可能会让程......
  • C++模板
    一、类型信息运算符typeid在C++中typeid可以获取数据的类型,但是需要加头文件typeinfofind/usr/include-nametypeinfotypeid是运算符,执行运算符函数,执行的返回类型是type_info类类型对象type_info中有个name的成员函数type_info中还重载了==运算符,可以直接比较......
  • java线程的ThreadLocal是线程变量
    java线程的localThread是线程局部变量,只能在线程内访问,方法有getsetremove.证明localThread只能在线程内访问的方法,在control层设置一个ThreadLocal,然后在service可以访问到ThreadLocal设置的值,另外就是浏览器的一次请求就是一个线程的请求.......
  • 标准C++ -- day09
    一、智能指针常规指针的缺点:当一个常规指针离开了作用域时,只有该指针变量本身占用的内存空间(4/8字节)会被释放,而它指向的内存空间不会自动释放,当free、delete、delete[]语句忘记执行或者无法执行,形成内存泄漏如何定位内存泄漏、如何预防内存泄漏智能指针的优点:......
  • 线程同步精要
    并发编程有两种基本模型:messagepassing&sharedmemory。线程同步的四项原则:首要原则是最低限度的共享对象,减少需要同步的场合,一个对象能不暴露给别的线程就不要暴露,如果要暴露,优先考虑immutable对象,实在不行才暴露可修改的对象,并用同步措施来充分保护它。其次是使用高级......
  • 线程安全的对象生命期管理
     编写线程安全的类不是难事,用同步原语保护内部状态即可。但是对象的生与死不能由对象自身拥有的mutex保护。racecondition:在即将析构一个对象时,从何而知此刻是否有别的线程正在执行该对象的成员函数?如何保证在执行成员函数期间,对象不会在另一个线程被析构?在调用某个对象的......