C++20 semaphore(信号量) 详解

2024-04-05 20:36

本文主要是介绍C++20 semaphore(信号量) 详解,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

头文件在C++20中是并发库技术规范(Technical Specification, TS)的一部分。信号量是同步原语,帮助控制多线程程序中对共享资源的访问。头文件提供了标准C++方式来使用信号量。

使用环境

Windows:VS中打开项目属性,修改C++语言标准。

Linux:GCC,版本至少应为10.1,编译命令中使用-std=c++20标志。

简单定义

你可以像这样创建一个信号量对象:

std::counting_semaphore<size_t> sem(1); // 用初始计数为1初始化一个信号量

std::counting_semaphore是一种允许指定数量的线程同时访问资源的信号量。在这个例子中,一次只有一个线程可以访问由sem保护的资源。

获取和释放

直接获取

要获取(锁定)信号量,你可以使用acquire方法:

sem.acquire();
// 关键段代码
sem.release();

acquire方法将信号量计数减一,有效地锁定它。release方法增加计数,释放信号量。

尝试获取

你也可以使用try_acquire方法来尝试获取信号量而不阻塞:

if (sem.try_acquire()) {// 成功获取了信号量// 关键段代码sem.release();
} else {// 信号量未被获取
}

带超时的等待

C++20还引入了try_acquire_for和try_acquire_until方法,以带超时的方式尝试获取信号量。

if (sem.try_acquire_for(std::chrono::seconds(1))) {// 在1秒内成功获取了信号量// 关键段代码sem.release();
} else {// 在1秒内未能获取信号量
}

信号量的类型

std::counting_semaphore

计数信号量是一种同步原语,允许多个线程在一定限制下访问共享资源。它是互斥锁或二进制信号量的泛化。

你可以用一个初始计数来初始化计数信号量,该计数代表可以同时无阻塞访问资源的线程数量。线程可以获取和释放计数,信号量的计数相应地增加或减少。如果线程尝试获取的计数超过了可用的数量,它将阻塞,直到计数变得可用。

// 展示如何使用counting_semaphore
#include <iostream>
#include <semaphore>
#include <thread>
using namespace std;// 用3个计数初始化信号量
counting_semaphore<10> semaphore(3);void worker(int id)
{// 获取semaphore.acquire();// 执行一些工作cout << "Thread " << id << " acquired the semaphore."<< endl;// 释放semaphore.release();cout << "Thread " << id << " released the semaphore."<< endl;
}int main()
{thread t1(worker, 1);thread t2(worker, 2);thread t3(worker, 3);t1.join();t2.join();t3.join();return 0;
}

输出结果

Thread 2 acquired the semaphore.
Thread 2 released the semaphore.
Thread 1 acquired the semaphore.
Thread 1 released the semaphore.
Thread 3 acquired the semaphore.
Thread 3 released the semaphore.

std::binary_semaphore

二进制信号量是一种更简单的信号量版本,它只能有两个值:0和1。

通常用于两个线程之间的基本互斥或信号传递。可以被视为具有更轻量级接口的互斥锁。类似于mutex。

// 展示二进制信号量的用法
#include <iostream>
#include <semaphore>
#include <thread>
using namespace std;// 用1个计数(二进制)初始化信号量
binary_semaphore semaphore(1);void worker(int id)
{// 获取信号量semaphore.acquire();cout << "Thread " << id << " acquired the semaphore."<< endl;// 执行一些工作semaphore.release();// 释放信号量cout << "Thread " << id << " released the semaphore."<< endl;
}int main()
{thread t1(worker, 1);thread t2(worker, 2);t1.join();t2.join();return 0;
}

输出结果

Thread 1 acquired the semaphore.
Thread 1 released the semaphore.
Thread 2 acquired the semaphore.
Thread 2 released the semaphore.

优点

信号量的优势如下:

  • 精细控制:信号量可以配置为允许特定数量的线程同时访问资源,实现资源的精细控制。
  • 通用性:信号量更加灵活多样,可以用来实现其他同步原语。
  • 多资源管理:计数信号量可以用来管理多个资源实例,适用于需要控制对资源池(如线程池或连接池)访问的场景。
  • 阻塞等待:信号量中的阻塞和等待机制允许线程等待直到资源再次可用。
  • 超时处理:在获取信号量时可以指定超时,使其更加实用。

例子:生产者消费者问题

#include <iostream>
#include <semaphore>
#include <thread>
using namespace std;const int buffer_size = 5;// 缓冲区大小
std::binary_semaphore b_mutex(1);
//容量为5 赋初值
std::counting_semaphore<buffer_size> b_full(0);
std::counting_semaphore<buffer_size> b_empty(5);
void Producer()
{while (true){b_empty.acquire();b_mutex.acquire();std::cout << "Producer\n";b_mutex.release();b_full.release();//模拟生成过程std::this_thread::sleep_for(std::chrono::seconds(2));}
}
void Consumer()
{while (true){b_full.acquire();b_mutex.acquire();std::cout << "Consumer\n";b_mutex.release();b_empty.release();//模拟消耗过程std::this_thread::sleep_for(std::chrono::seconds(2));}
}
int main()
{thread t0(Producer);thread t1(Producer);thread t2(Consumer);thread t3(Consumer);t0.join();t1.join();t2.join();t3.join();
}

关键组件

b_mutex:一个二进制信号量,用作互斥锁,保证在任何时刻只有一个线程可以操作缓冲区。这是为了防止多个生产者或消费者同时访问缓冲区,导致数据不一致的问题。

b_full:一个计数信号量,表示缓冲区中已填充的项数。初始化为0,因为一开始缓冲区是空的。

b_empty:另一个计数信号量,表示缓冲区中空闲位置的数量。初始化为缓冲区的大小,因为起初整个缓冲区都是空的。

生产者(Producer)

等待一个空闲位置(b_empty.acquire();),这表示生产者在缓冲区中找到了一个可以放置新生产项的位置。

获取互斥锁(b_mutex.acquire();),进行生产操作(这里通过打印"Producer"模拟),然后释放互斥锁(b_mutex.release();),这样其他线程(生产者或消费者)就可以访问缓冲区了。

生产完成后,释放一个已满位置的信号(b_full.release();),告知消费者缓冲区中有项可被消费。模拟生产过程中的延迟(std::this_thread::sleep_for(std::chrono::seconds(2));)。

消费者(Consumer)

等待一个已满位置(b_full.acquire();),这表示消费者在缓冲区中找到了一个可以消费的项。

获取互斥锁(b_mutex.acquire();),进行消费操作(这里通过打印"Consumer"模拟),然后释放互斥锁(b_mutex.release();),这样其他线程(生产者或消费者)就可以访问缓冲区了。

消费完成后,释放一个空闲位置的信号(b_empty.release();),告知生产者缓冲区中有位置可用于生产新的项。模拟消费过程中的延迟(std::this_thread::sleep_for(std::chrono::seconds(2));)。

这篇关于C++20 semaphore(信号量) 详解的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/878087

相关文章

MySQL 8 中的一个强大功能 JSON_TABLE示例详解

《MySQL8中的一个强大功能JSON_TABLE示例详解》JSON_TABLE是MySQL8中引入的一个强大功能,它允许用户将JSON数据转换为关系表格式,从而可以更方便地在SQL查询中处理J... 目录基本语法示例示例查询解释应用场景不适用场景1. ‌jsON 数据结构过于复杂或动态变化‌2. ‌性能要

Python实现终端清屏的几种方式详解

《Python实现终端清屏的几种方式详解》在使用Python进行终端交互式编程时,我们经常需要清空当前终端屏幕的内容,本文为大家整理了几种常见的实现方法,有需要的小伙伴可以参考下... 目录方法一:使用 `os` 模块调用系统命令方法二:使用 `subprocess` 模块执行命令方法三:打印多个换行符模拟

MySQL字符串常用函数详解

《MySQL字符串常用函数详解》本文给大家介绍MySQL字符串常用函数,本文结合实例代码给大家介绍的非常详细,对大家学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录mysql字符串常用函数一、获取二、大小写转换三、拼接四、截取五、比较、反转、替换六、去空白、填充MySQL字符串常用函数一、

Java中Arrays类和Collections类常用方法示例详解

《Java中Arrays类和Collections类常用方法示例详解》本文总结了Java中Arrays和Collections类的常用方法,涵盖数组填充、排序、搜索、复制、列表转换等操作,帮助开发者高... 目录Arrays.fill()相关用法Arrays.toString()Arrays.sort()A

Python 字典 (Dictionary)使用详解

《Python字典(Dictionary)使用详解》字典是python中最重要,最常用的数据结构之一,它提供了高效的键值对存储和查找能力,:本文主要介绍Python字典(Dictionary)... 目录字典1.基本特性2.创建字典3.访问元素4.修改字典5.删除元素6.字典遍历7.字典的高级特性默认字典

MySQL 主从复制部署及验证(示例详解)

《MySQL主从复制部署及验证(示例详解)》本文介绍MySQL主从复制部署步骤及学校管理数据库创建脚本,包含表结构设计、示例数据插入和查询语句,用于验证主从同步功能,感兴趣的朋友一起看看吧... 目录mysql 主从复制部署指南部署步骤1.环境准备2. 主服务器配置3. 创建复制用户4. 获取主服务器状态5

一文详解如何使用Java获取PDF页面信息

《一文详解如何使用Java获取PDF页面信息》了解PDF页面属性是我们在处理文档、内容提取、打印设置或页面重组等任务时不可或缺的一环,下面我们就来看看如何使用Java语言获取这些信息吧... 目录引言一、安装和引入PDF处理库引入依赖二、获取 PDF 页数三、获取页面尺寸(宽高)四、获取页面旋转角度五、判断

Spring Boot中的路径变量示例详解

《SpringBoot中的路径变量示例详解》SpringBoot中PathVariable通过@PathVariable注解实现URL参数与方法参数绑定,支持多参数接收、类型转换、可选参数、默认值及... 目录一. 基本用法与参数映射1.路径定义2.参数绑定&nhttp://www.chinasem.cnbs

C++中全局变量和局部变量的区别

《C++中全局变量和局部变量的区别》本文主要介绍了C++中全局变量和局部变量的区别,全局变量和局部变量在作用域和生命周期上有显著的区别,下面就来介绍一下,感兴趣的可以了解一下... 目录一、全局变量定义生命周期存储位置代码示例输出二、局部变量定义生命周期存储位置代码示例输出三、全局变量和局部变量的区别作用域

C++中assign函数的使用

《C++中assign函数的使用》在C++标准模板库中,std::list等容器都提供了assign成员函数,它比操作符更灵活,支持多种初始化方式,下面就来介绍一下assign的用法,具有一定的参考价... 目录​1.assign的基本功能​​语法​2. 具体用法示例​​​(1) 填充n个相同值​​(2)