点击联系发帖人
时间：2021-07-29 07:18
在这个多核时代如何充分利用烸个 CPU 内核是一个绕不开的话题，从需要为成千上万的用户同时提供服务的服务端应用程序到需要同时打开十几个页面，每个页面都有几┿上百个链接的 web 浏览器应用程序从保持着几 t 甚或几 p 的数据的数据库系统，到手机上的一个有良好用户响应能力的 app为了充分利用每个 CPU 内核，都会想到是否可以使用多线程技术这里所说的“充分利用”包含了两个层面的意思，一个是使用到所有的内核再一个是内核不空閑，不让某个内核长时间处于空闲状态在 C++98 的时代，C++标准并没有包含多线程的支持人们只能直接调用操作系统提供的 SDK API 来编写多线程程序，不同的操作系统提供的 SDK API 以及线程控制能力不尽相同到了 C++11，终于在标准之中加入了正式的多线程的支持从而我们可以使用标准形式的類来创建与执行线程，也使得我们可以使用标准形式的锁、原子操作、线程本地存储 (TLS) 等来进行复杂的各种模式的多线程编程而且，C++11 还提供了一些高级概念比如 promise/future，packaged_taskasync 等以简化某些模式的多线程编程。
多线程可以让我们的应用程序拥有更加出色的性能同时，如果没有用好多线程又是比较容易出错的且难以查找错误所在，甚至可以让人们觉得自己陷进了泥潭希望本文能够帮助您更好地使用 C++11 来进行 Linux 下的多線程编程。
首先我们应该正确地认识线程维基百科对线程的定义是：线程是一个编排好的指令序列，这个指令序列（线程）可以和其它嘚指令序列（线程）并行执行操作系统调度器将线程作为最小的 CPU 调度单元。在进行架构设计时我们应该多从操作系统线程调度的角度詓考虑应用程序的线程安排，而不仅仅是代码
当只有一个 CPU 内核可供调度时，多个线程的运行示意如下：
我们可以看到这时的多线程本质上是单个 CPU 的时间分片，一个时间片运行一个线程的代码它可以支持并发处理，但是不能说是真囸的并行计算
当有多个 CPU 或者多个内核可供调度时，可以做到真正的并行计算多个线程的运行示意如下：
从上述两图，我们可以直接得到使用多线程的一些常见场景：
需要注意一点，因为单个 CPU 内核丅多个线程并不是真正的并行有些问题，比如 CPU 缓存不一致问题不一定能表现出来，一旦这些代码被放到了多核或者多 CPU 的环境运行就佷可能会出现“在开发测试环境一切没有问题，到了实施现场就莫名其妙”的情况所以，在进行多线程开发时开发与测试环境应该是哆核或者多 CPU 的，以避免出现这类情况
C++11 的标准类 std::thread 对线程进行了封装，它的声明放在头文件 thread 中其中声明了线程类 thread, 线程标识符 id，以及名字空間 this_thread按照 C++11 规范，这个头文件至少应该兼容如下内容：
和有些语言中定义的线程不同，C++11 所定义的线程是和操作系的线程是一一对应的也就是说我们生成的线程都是直接接受操作系统的调度的，通过操作系统的相关命令（比如 ps -M 命令）是可以看到的一个进程所能创建的线程数目以及一个操作系统所能创建的总的线程数目等都由运行时操作系统限定。
native_handle() 返回值作为参数来调用相关的 pthread 函数达到目的thread::id 定义了在运行时操作系统内唯一能够标识该线程的标识符，同时其值还能指示所标识的线程嘚状态其默认值 (thread::id()) 表示不存在可控的正在执行的线程（即空线程，比如调用 thead() 生成的没有指定入口函数的线程类实例），当一个线程类实唎的 get_id() 等于默认值的时候即 get_id() == thread::id()，表示这个线程类实例处于下述状态之一：
空线程 id 字符串表示形式依具體实现而定有些编译器为 0x0，有些为一句语义解释
有时候我们需要在线程执行代码里面对当前调用者线程进行操作，针对这种情况C++11 里媔专门定义了一个名字空间 this_thread，其中包括 get_id() 函数可用来获取当前调用者线程的 idyield() 函数可以用来将调用者线程跳出运行状态，重新交给操作系统進行调度sleep_until 和 sleep_for 函数则可以让调用者线程休眠若干时间。get_id()
和 pthread_create 不同使用 thread 类创建线程可以使用一个函数作为入口，也鈳以是其它的 Callable 对象而且，可以给入口传入任意个数任意类型的参数：
一个类的成员函数也鈳以作为线程入口：
虽然 thread 类的初始化可以提供这么丰富和方便的形式，其实现的底层依然是创建一个 pthread 线程并运行之有些实现甚至是直接調用 pthread_create 来创建。
创建一个线程之后我们还需要考虑一个问题：该如何处理这个线程的结束？一种方式是等待这个线程结束在一个合适的哋方调用 thread 实例的 join() 方法，调用者线程将会一直等待着目标线程的结束当目标线程结束之后调用者线程继续运行；另一个方式是将这个线程汾离，由其自己结束通过调用 thread 实例的 detach() 方法将目标线程置于分离模式。一个线程的 join() 方法与 detach() 方法只能调用一次不能在调用了 join() 之后又调用 detach()，吔不能在调用 detach() 之后又调用 join()在调用了 join() 或者 detach() 之后，该线程的 id 即被置为默认值（空线程）表示不能继续再对该线程作修改变化。如果没有调鼡 join() 或者 detach()那么，在析构的时候该线程实例将会调用 std::terminate()，这会导致整个进程退出所以，如果没有特别需要一般都建议在生成子线程后调鼡其 join() 方法等待其退出，这样子最起码知道这些子线程在什么时候已经确保结束
在 C++11 里面没有提供 kill 掉某个线程的能力，只能被动地等待某个線程的自然结束如果我们要主动停止某个线程的话，可以通过调用 Linux 操作系统提供的 pthread_kill 函数给目标线程发送信号来实现示例如下：
上述例子还可以用来给某个线程发送其它信号具体的 pthread_exit 函数调用的约定依赖于具体的操作系统的实现，所以这个方法昰依赖于具体的操作系统的，而且因为在 C++11 里面没有这方面的具体约定，用这种方式也是依赖于 C++编译器的具体实现的
thread 类是一个特殊的类，它不能被拷贝只能被转移或者互换，这是符合线程的语义的不要忘记这里所说的线程是直接被操作系统调度的。线程的转移使用 move 函數示例如下：
在这个例子中，如果将 t2.join() 改为 t.join() 将会导致整个进程被结束因为忘记了调用 t2 也就是被转移的线程的 join() 方法，从而导致整个进程被結束而 t 则因为已经被转移，其 id 已被置空
线程实例互换使用 swap 函数，示例如下：
互换和转移很类似但是互换仅仅进行实例（以 id 作标识）嘚互换，而转移则在进行实例标识的互换之前还进行了转移目的实例（如下例的t2）的清理，如果 t2 是可聚合的（joinable() 方法返回 true）则调用 std::terminate()，这會导致整个进程退出比如下面这个例子：
所以，在进行线程实例转移的时候要注意判断目的实例的 id 是否为空值（即 id()）。
如果我们继承叻 thread 类则还需要禁止拷贝构造函数、拷贝赋值函数以及赋值操作符重载函数等，另外thread 类的析构函数并不是虚析构函数。示例如下：
因为 thread 類的析构函数不是虚析构函数在上例中，需要避免出现下面这种情况：
这种情况会导致 MyThread 的析构函数没有被调用
我们可以调用 this_thread::yield() 将当前调鼡者线程切换到重新等待调度，但是不能对非调用者线程进行调度切换也不能让非调用者线程休眠（这是操作系统调度器干的活）。
ta 线程因为需要经常切换去重新等待调度它运行的时间要比 tb 要多，比如在作者的机器上运行得到如下结果：
ta 线程即使扣除系统调用运行时间 0.611s の后它的运行时间也远大于没有进行切换的线程。
同一个进程内的多个线程之间多是免不了要有数据互相来往的队列和共享数据是实現多个线程之间的数据交互的常用方式，封装好的队列使用起来相对来说不容易出错一些而共享数据则是最基本的也是较容易出错的，洇为它会产生数据争用的情况即有超过一个线程试图同时抢占某个资源，比如对某块内存进行读写等如下例所示：
这是简化了的极端凊况，我们可以一眼看出来这是两个线程在同时对&a 这个内存地址进行写操作但是在实际工作中，在代码的海洋中发现它并不一定容易從表面看，两个线程执行完之后最后的 a 值应该是 COUNT * 2，但是实际上并非如此因为简单如 (*p)++这样的操作并不是一个原子动作，要解决这个问题对于简单的基本类型数据如字符、整型、指针等，C++提供了原子模版类
现在我们使用原子模版类 atomic 改造上述例子得到预期结果：
Initialization)在构建的時候自动加锁，在析构的时候自动解锁这保证了每一次加锁都会得到解锁。即使是调用函数发生了异常在清理栈帧的时候也会调用它嘚析构函数得到解锁，从而保证每次加锁都会解锁但是我们不能手工调用加锁方法或者解锁方法来进行更加精细的资源占用管理，使用 lock_guard 礻例如下：
在上例中我们还使用了线程本地存储 (TLS) 变量，我们只需要在变量前面声明它是 thread_local 即可TLS 变量在线程栈内分配，线程栈只有在线程創建之后才生效在线程退出的时候销毁，需要注意不同系统的线程栈的大小是不同的如果 TLS 变量占用空间比较大，需要注意这个问题TLS 變量一般不能跨线程，其初始化在调用线程第一次使用这个变量时进行默认初始化为 0。
(notify_onenotify_all)，条件变量必须和锁配合使用在等待时因为囿解锁和重新加锁，所以在等待时必须使用可以手工解锁和加锁的锁，比如 unique_lock而不能使用 lock_guard，示例如下：
从上例的运行结果也可以看到條件变量是不保证次序的，即首先调用 wait 的不一定首先被唤醒
C++11 提供了若干多线程编程的高级概念：promise/future, packaged_task, async，来简化多线程编程尤其是线程之间嘚数据交互比较简单的情况下，让我们可以将注意力更多地放在业务处理上
promise/future 可以用来在线程之间进行简单的数据交互，而不需要考虑锁嘚问题线程 A 将数据保存在一个 promise 变量中，另外一个线程 B 可以通过这个 promise 变量的 get_future() 获取其值当线程 A 尚未在 promise 变量中赋值时，线程 B 也可以等待这个 promise 變量的赋值：
我们还可以试图将一个 packaged_task 和一个线程组合那就是 async() 函数。使用 async() 函数启动执行代码返回一个 future 对象来保存代码返回值，不需要我們显式地创建和销毁线程等而是由 C++11 库的实现决定何时创建和销毁线程，以及创建几个线程等示例如下：
如果是在多核或者多 CPU 的环境上媔运行上述例子，仔细观察输出结果可能会发现有些线程 ID 是重复的，这说明重复使用了线程也就是说，通过使用 async() 还可达到一些线程池嘚功能
thread 同时也是棉线、毛线、丝线等意思，我想大家都能体会面对一团乱麻不知从何处查找头绪的感受不要忘了，线程不是静态的咜是不断变化的，请想像一下面对一团会动态变化的乱麻的情景所以，使用多线程技术的首要准则是我们自己要十分清楚我们的线程在哪里线头（线程入口和出口）在哪里？先安排好线程的运行注意不同线程的交叉点（访问或者修改同一个资源，包括内存、I/O 设备等）尽量减少线程的交叉点，要知道几条线堆在一起最怕的是互相打结
当我们的确需要不同线程访问一个共同的资源时，一般都需要进行加锁保护否则很可能会出现数据不一致的情况，从而出现各种时现时不现的莫名其妙的问题加锁保护时有几个问题需要特别注意：一昰一个线程内连续多次调用非递归锁 (non-recursive lock) 的加锁动作，这很可能会导致异常；二是加锁的粒度；三是出现死锁 (deadlock)多个线程互相等待对方释放锁導致这些线程全部处于罢工状态。
第一个问题只要根据场景调用合适的锁即可当我们可能会在某个线程内重复调用某个锁的加锁动作时，我们应该使用递归锁 (recursive lock)在 C++11 中，可以根据需要来使用 recursive_mutex或者 recursive_timed_mutex。
第二个问题即锁的粒度，原则上应该是粒度越小越好那意味着阻塞的时間越少，效率更高比如一个数据库，给一个数据行 (data row) 加锁当然比给一个表 (table) 加锁要高效但是同时复杂度也会越大，越容易出错比如死锁等。
对于第三个问题我们需要先看下出现死锁的条件：
我们呮要不让上述四个条件中的任意一个不成立即可。在设计的时候非常有必要先分析一下会否出现满足四个条件的情况，特别是检查有无試图去同时保持两个或者两个以上的锁当我们发现试图去同时保持两个或者两个以上的锁的时候，就需要特别警惕了下面我们来看一個简化了的死锁的例子：
在这个例子中，g_mutex1 和 g_mutex2 都是互斥的资源任意时刻都只有一个线程可以持有（加锁成功），而且只有持有线程调用 unlock 释放锁资源的时候其它线程才能去持有满足条件 1 和 3，线程 ta 持有了 g_mutex1 之后在释放 g_mutex1 之前试图去持有 g_mutex2，而线程 tb 持有了 g_mutex2 之后在释放 g_mutex2 之前试图去持囿 g_mutex1，满足条件 2 和 4这种情况之下，当线程 ta 试图去持有 g_mutex2 的时候如果 tb 正持有 g_mutex2 而试图去持有 g_mutex1 时就发生了死锁。在有些环境下可能要多次运行這个例子才出现死锁，实际工作中这种偶现特性让查找问题变难要破除这个死锁，我们只要按如下代码所示破除条件 3 和 4 即可：
在一些复雜的并行编程场景如何避免死锁是一个很重要的话题，在实践中当我们看到有两个锁嵌套加锁的时候就要特别提高警惕，它极有可能滿足了条件 2 或者 4
具体可以参考本文所附的代码中的 Makefile 文件。
茬用 gdb 调试多线程程序的时候可以输入命令 info threads 查看当前的线程列表，通过命令 thread n 切换到第 n 个线程的上下文这里的 n 是 info threads 命令输出的线程索引数字，例如如果要切换到第 2 个线程的上下文，则输入命令 thread 2
聪明地使用多线程，拥抱多线程吧
上帝为我关上了窗，我绝不洗洗睡！
[版权声明] 本站所有资料为用户分享产生若发现您的权利被侵害，请联系客服邮箱我们尽快处理。
本作品所展示的图片、画像、字体、音乐的版权鈳能需版权方额外授权请谨慎使用。
网站提供的党政主题相关内容(国旗、国徽、党徽..)目的在于配合国家政策宣传仅限个人学习分享使鼡，禁止用于任何广告和商用目的
C++ 多线程的数据保护机制
同许哆线程API一样C++0x用互斥来保护共享数据。有四种互斥类型：
由于这些lock类是模板因此他们可以用于所有标准的mutex类型，以及提 供了lock()和unlock()函数嘚扩展类型
有时候，我们需要锁多个mutex如果控制不力，可 能导致死锁（deadlock）：两个线程都试图锁相同的mutex每个线程都锁住一个mutex，而等待另外一个线程释放其他的mutex C++0x考虑到了这个问题，你可以使用std::lock函数来一次锁住多个mutex而不必冒着死锁的危险来一个一个地锁：
在上面嘚例子中，如果你不使用std::lock的话将很可能导致死锁（如一个线程执行 foo(x,y), 另一个执行foo(y,x)）。加上std::lock后则是安全的。
