【玩转RT-Thread】线程间同步(一) 信号量

简介: 【玩转RT-Thread】线程间同步(一) 信号量

一、概述:

多个执行单元(线程、中断)同时执行临界区,操作临界资源,会导致竟态产生,为了解决这种竟态问题,RT-Thread OS提供了如下几种同步互斥机制:

信号量(semaphore)、互斥量(mutex)、和事件集(event)

二、信号量

1、简述

信号量是一种轻型的用于解决线程间同步问题的内核对象,线程可以获取或释放它,从而达到同步互斥的目的。

信号量工作示意图如下图所示,每个信号量对象都有一个信号量值和一个线程等待队列,信号量的值对应了信号量对象的实例数目、资源数目,假如信号量值为 5,则表示共有 5 个信号量实例(资源)可以被使用,当信号量实例数目为零时,再申请该信号量的线程就会被挂起在该信号量的等待队列上,等待可用的信号量实例(资源)。

2、信号量结构体

struct rt_semaphore
{
    struct rt_ipc_object parent;                        /**< 继承自ipc_object类 */
    rt_uint16_t          value;                         /**< value of semaphore. */
    rt_uint16_t          reserved;                      /**< reserved field 预留*/
};

当线程对资源进行获取时,value值进行减一操作;直到该信号量被释放,value进行加一操作。

3、信号量使用及管理

对一个信号量的操作包含:创建/初始化信号量、获取信号量、释放信号量、删除/脱离信号量

1)动态创建信号量

当调用这个函数时,系统将先从对象管理器中分配一个 semaphore 对象,并初始化这个对象,然后初始化父类 IPC 对象以及与 semaphore 相关的部分。在创建信号量指定的参数中,信号量标志参数决定了当信号量不可用时,多个线程等待的排队方式。

当选择 RT_IPC_FLAG_FIFO(先进先出)方式时,那么等待线程队列将按照先进先出的方式排队,先进入的线程将先获得等待的信号量;

当选择 RT_IPC_FLAG_PRIO(优先级等待)方式时,等待线程队列将按照优先级进行排队,优先级高的等待线程将先获得等待的信号量。

函数声明

rt_sem_t rt_sem_create(const char *name, rt_uint32_t value, rt_uint8_t flag);

参数介绍

注意:

(1)此处的*name定义最多只能显示八个字符

(2)查看rt_sem_create()函数返回值是-->typedef struct rt_semaphore *rt_sem_t;,也就是一个重命名的结构体rt_semaphore

// flag值  如下
#define RT_IPC_FLAG_FIFO                0x00            /**< FIFOed IPC. @ref IPC.按照先进先出的方式获取信号量资源 */
#define RT_IPC_FLAG_PRIO                0x01            /**< PRIOed IPC. @ref IPC.按线程优先级获取信号量资源 */

2)动态创建的信号量删除

系统不再使用信号量时,可通过删除信号量以释放系统资源,适用于动态创建的信号量。

调用这个函数时,系统将删除这个信号量。如果删除该信号量时,有线程正在等待该信号量,那么删除操作会先唤醒等待在该信号量上的线程(等待线程的返回值是 - RT_ERROR),然后再释放信号量的内存资源。

函数声明

rt_err_t rt_sem_delete(rt_sem_t sem);

实例

#include <rtthread.h>
#include <rtdevice.h>
#include <board.h>
#include <rtdbg.h>
rt_sem_t sem1;
int main(void)
{
    sem1 = rt_sem_create("sem_1",1,RT_IPC_FLAG_FIFO);
    if(sem1 == RT_NULL)
    {
        LOG_E("rt_sem_create is failure...\n");
    }
    LOG_D("rt_sem_create is success...\n");
    return 0;
}

3)静态创建信号量

描述

对于静态信号量对象,它的内存空间在编译时期就被编译器分配出来,放在读写数据段或未初始化数据段上,此时使用信号量就不再需要使用 rt_sem_create 接口来创建它,而只需在使用前对它进行初始化即可。

函数声明

rt_err_t rt_sem_init(rt_sem_t    sem,
                     const char *name,
                     rt_uint32_t value,
                     rt_uint8_t  flag);

参数描述

4)脱离信号量

描述

脱离信号量就是让信号量对象从内核对象管理器中脱离,适用于静态初始化的信号量

函数声明

rt_err_t rt_sem_detach(rt_sem_t sem);

5)获取信号量

描述

线程通过获取信号量来获得信号量资源实例,当信号量值大于零时,线程将获得信号量,并且相应的信号量值会减 1。

如果信号量的值等于零,那么说明当前信号量资源实例不可用,申请该信号量的线程将根据 time 参数的情况选择直接返回、或挂起等待一段时间、或永久等待,直到其他线程或中断释放该信号量。

如果在参数 time 指定的时间内依然得不到信号量,线程将超时返回,返回值是 - RT_ETIMEOUT

函数声明

rt_err_t rt_sem_take (rt_sem_t sem, rt_int32_t time);

参数描述

// time参数
#define RT_WAITING_FOREVER              -1              /**< Block forever until get resource. */
#define RT_WAITING_NO                   0               /**< Non-block. */
// 扩展:
rt_err_t rt_sem_trytake(rt_sem_t sem); // 无等待获取信号量
// 这个函数与 rt_sem_take(sem, RT_WAITING_NO) 的作用相同,即当线程申请的信号量资源实例不可用的时候,它不会等待在该信号量上,而是直接返回 - RT_ETIMEOUT。

6)信号量释放

函数声明

rt_err_t rt_sem_release(rt_sem_t sem);

描述

例如当信号量的值等于零时,并且有线程等待这个信号量时,释放信号量将唤醒等待在该信号量线程队列中的第一个线程,由它获取信号量;否则将把信号量的值加 1。

4、信号量实例演示

这里可以看到创建了两个线程,而且线程的优先级都是符合我们定义的20,但是查看线程状态可以发现,线程1和线程2都是阻塞态。这是因为我们在线程的入口函数中使用了mdelay延时函数,执行这个函数,线程会短暂地进入阻塞态

由于我们在线程2的入口函数中执行了信号量获取函数,但是我们在初始化信号量2的时候设定的初值是0,所以此时线程2由于未获取到信号量而陷入阻塞态

查看信号量设定的标志位是RT_IPC_FLAG_FIFO,是按照先进先出的方式进行信号量的获取的,所以在函数的执行顺序中可以发现都是按照线程1->线程2->线程1->线程2…的顺序执行的,这样就实现了线程的并发互斥运行。

最后附上测试源代码

#include <rtthread.h>
#include <rtdevice.h>
#include <board.h>
#include <rtdbg.h>
rt_sem_t sem1;
struct rt_semaphore sem2;
rt_thread_t th1,th2;
int flags = 0;
void th1_entry(void *parameter)
{
    while(1)
    {
        rt_thread_mdelay(8000);
        rt_sem_take(sem1, RT_WAITING_FOREVER);// 获取信号量
        flags++;
        if(flags == 100)
            flags = 0;
        rt_kprintf("th1_entry [%d]\n",flags);
        rt_sem_release(&sem2);// 对获取的信号量进行释放
    }
}
void th2_entry(void *parameter)
{
    while(1)
    {
        rt_sem_take(&sem2, RT_WAITING_FOREVER);// 获取信号量
        if(flags > 0)
            flags--;
        rt_kprintf("th2_entry [%d]\n",flags);
        rt_sem_release(sem1);// 对获取的信号量进行释放
        rt_thread_mdelay(1000);
    }
}
int main(void)
{
    int ret = 0;
    sem1 = rt_sem_create("sem_1",1,RT_IPC_FLAG_FIFO);
    if(sem1 == RT_NULL)
    {
        LOG_E("sem1 rt_sem_create is failure...\n");
    }
    LOG_D("sem1 rt_sem_create is success...\n");
    ret = rt_sem_init(&sem2, "sem2", 0, RT_IPC_FLAG_FIFO);
    if(ret < 0)
    {
        LOG_E("sem2 rt_sem_create is failure...\n");
        return ret;
    }
    LOG_D("sem2 rt_sem_init successed...\n");
    th1 = rt_thread_create("th1", th1_entry, NULL, 512, 20, 5);
    if(th1 == RT_NULL)
    {
        LOG_E("th1 rt_thread_create failed...\n");
        return -ENOMEM;
    }
    LOG_D("th1 rt_thread_create successed...\n");
    th2 = rt_thread_create("th2", th2_entry, NULL, 512, 20, 5);
    if(th2 == RT_NULL)
    {
        LOG_E("th2 rt_thread_create failed...\n");
        return -ENOMEM;
    }
    LOG_D("th2 rt_thread_create successed...\n");
    rt_thread_startup(th1);
    rt_thread_startup(th2);
    return 0;
}


目录
相关文章
|
4月前
|
编解码 数据安全/隐私保护 计算机视觉
Opencv学习笔记(十):同步和异步(多线程)操作打开海康摄像头
如何使用OpenCV进行同步和异步操作来打开海康摄像头,并提供了相关的代码示例。
158 1
Opencv学习笔记(十):同步和异步(多线程)操作打开海康摄像头
|
3月前
|
Java 调度
Java 线程同步的四种方式,最全详解,建议收藏!
本文详细解析了Java线程同步的四种方式:synchronized关键字、ReentrantLock、原子变量和ThreadLocal,通过实例代码和对比分析,帮助你深入理解线程同步机制。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
Java 线程同步的四种方式,最全详解,建议收藏!
|
4月前
|
安全 Java 开发者
Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用
本文深入解析了Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用。通过示例代码展示了如何正确使用这些方法,并分享了最佳实践,帮助开发者避免常见陷阱,提高多线程程序的稳定性和效率。
75 1
|
4月前
|
运维 API 计算机视觉
深度解密协程锁、信号量以及线程锁的实现原理
深度解密协程锁、信号量以及线程锁的实现原理
62 2
|
4月前
|
安全 调度 C#
STA模型、同步上下文和多线程、异步调度
【10月更文挑战第19天】本文介绍了 STA 模型、同步上下文和多线程、异步调度的概念及其优缺点。STA 模型适用于单线程环境,确保资源访问的顺序性;同步上下文和多线程提高了程序的并发性和响应性,但增加了复杂性;异步调度提升了程序的响应性和资源利用率,但也带来了编程复杂性和错误处理的挑战。选择合适的模型需根据具体应用场景和需求进行权衡。
|
4月前
多线程通信和同步的方式有哪些?
【10月更文挑战第6天】
179 0
|
5月前
|
Java 数据中心 微服务
Java高级知识:线程池隔离与信号量隔离的实战应用
在Java并发编程中,线程池隔离与信号量隔离是两种常用的资源隔离技术,它们在提高系统稳定性、防止系统过载方面发挥着重要作用。
94 0
|
6月前
|
开发者 C# UED
WPF与多媒体:解锁音频视频播放新姿势——从界面设计到代码实践,全方位教你如何在WPF应用中集成流畅的多媒体功能
【8月更文挑战第31天】本文以随笔形式介绍了如何在WPF应用中集成音频和视频播放功能。通过使用MediaElement控件,开发者能轻松创建多媒体应用程序。文章详细展示了从创建WPF项目到设计UI及实现媒体控制逻辑的过程,并提供了完整的示例代码。此外,还介绍了如何添加进度条等额外功能以增强用户体验。希望本文能为WPF开发者提供实用的技术指导与灵感。
205 0
|
2月前
|
NoSQL Redis
单线程传奇Redis,为何引入多线程?
Redis 4.0 引入多线程支持,主要用于后台对象删除、处理阻塞命令和网络 I/O 等操作,以提高并发性和性能。尽管如此,Redis 仍保留单线程执行模型处理客户端请求,确保高效性和简单性。多线程仅用于优化后台任务,如异步删除过期对象和分担读写操作,从而提升整体性能。
70 1
|
4月前
|
存储 消息中间件 资源调度
C++ 多线程之初识多线程
这篇文章介绍了C++多线程的基本概念,包括进程和线程的定义、并发的实现方式,以及如何在C++中创建和管理线程,包括使用`std::thread`库、线程的join和detach方法,并通过示例代码展示了如何创建和使用多线程。
77 1