TinyWebServer学习笔记-互斥锁、信号量、条件变量

这篇具有很好参考价值的文章主要介绍了TinyWebServer学习笔记-互斥锁、信号量、条件变量。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

为什么要使用锁、信号量、条件变量?

网站不可能是单线程的,否则网站的性能和响应都会收到严重的影响。因此,这个项目一定是运行在多线程条件下的。而在多线程条件下,对共享资源的互斥访问就极其重要。

为什么要将资源封装成类?

首先,我们要明确资源的使用一般有三个步骤:

1、获取资源

2、使用资源

3、释放资源

然而,大多数情况下,我们一定能做到前两点,而总是忘记第三步,这就会造成资源的泄露。为了解决这个问题,提出了RAII方案,中文翻译是资源获取即初始化,也就是使用局部对象来管理资源的技术。

最直观的就是将资源封装成类, 在构造函数中获取资源,在析构函数中释放资源,这样当变量离开了作用域后,编译器会调用析构函数,而析构函数会帮助我们将资源释放掉,这样就避免了我们忘记释放资源的情况。

本项目中,作者就将锁、互斥量、条件变量进行了封装。有以下好处:

  1. 自动资源管理:RAII模式允许资源的获取和释放与对象的生命周期绑定在一起。当对象被创建时,资源被获取;当对象被销毁时,资源被释放。这消除了手动管理资源的需要,减少了错误的机会。

  2. 异常安全性:RAII模式提供了异常安全性,因为资源的释放操作通常在对象的析构函数中执行。如果在使用资源的过程中发生异常,对象的析构函数会被自动调用,确保资源被正确释放,防止资源泄漏。

  3. 避免忘记释放资源:使用RAII模式,开发人员不需要显式地记住在何处释放资源。资源的释放是自动的,因此避免了因忘记释放资源而引发的问题。

  4. 代码可读性:RAII模式使代码更加清晰和容易理解。资源的获取和释放操作都在对象的构造函数和析构函数中,使得代码更加自文档化。

  5. 资源的精确生命周期控制:RAII模式允许在对象的生命周期内对资源的生命周期进行精确的控制。资源在对象的构造和析构之间一直存在,不会在对象的其他方法之外被访问。

  6. 并发安全性:RAII模式可以用于管理锁、信号量等同步资源,确保线程安全性。资源在锁住和释放锁时被获取和释放,从而避免了竞态条件和死锁等问题。

 互斥锁、条件变量、信号量是如何工作的?

互斥锁:提供互斥访问的能力来确保同一时间只有一个线程能够访问共享资源。

        1. 锁初始化:创建锁并进行初始化;

        2. 加锁:当线程需要访问共享资源时,尝试获取互斥锁,如果已经被别的线程占用,那么该线程会被阻塞,直到锁可用;

        3. 访问共享资源:获取锁后,线程访问共享资源;

        4. 解锁:该线程访问完共享资源后,释放互斥锁,使其他等待的线程可以获得锁并访问资源。

条件变量:通常和互斥锁一起使用,条件变量用于等待某个条件满足后再继续执行。

        1. 等待条件:线程获取互斥锁后,发现条件不足,进入阻塞状态,释放互斥锁,让其他进程可以访问共享资源;

        2. 唤醒等待进程:当条件满足后,某个线程通过条件变量发出信号,唤醒一个或多个等待的线程,这些线程被唤醒后后会尝试重新获取互斥锁。

信号量:用于控制多个线程对有限资源的访问。通常有两种:

        1.二进制信号量:非0即1,用于互斥访问共享资源。等待信号量为1时获得访问权,将信号量设置为0,访问结束后将信号量值设为1;

        2. 计数信号量:可以具有>1的值,控制多个线程对一组有限资源的访问。线程获得资源信号量值变小;释放资源信号量值变大,当信号量值为0时需要阻塞线程。

下面我们来看作者的源代码:

#ifndef LOCKER_H
#define LOCKER_H

#include <exception>
#include <pthread.h>
#include <semaphore.h>

class sem
{
public:
    sem()
    {
        if (sem_init(&m_sem, 0, 0) != 0)
        {
            throw std::exception();
        }
    }
    sem(int num)
    {
        if (sem_init(&m_sem, 0, num) != 0)
        {
            throw std::exception();
        }
    }
    ~sem()
    {
        sem_destroy(&m_sem);
    }
    bool wait()
    {
        return sem_wait(&m_sem) == 0;
    }
    bool post()
    {
        return sem_post(&m_sem) == 0;
    }

private:
    sem_t m_sem;
};
class locker
{
public:
    locker()
    {
        if (pthread_mutex_init(&m_mutex, NULL) != 0)
        {
            throw std::exception();
        }
    }
    ~locker()
    {
        pthread_mutex_destroy(&m_mutex);
    }
    bool lock()
    {
        return pthread_mutex_lock(&m_mutex) == 0;
    }
    bool unlock()
    {
        return pthread_mutex_unlock(&m_mutex) == 0;
    }
    pthread_mutex_t *get()
    {
        return &m_mutex;
    }

private:
    pthread_mutex_t m_mutex;
};
class cond
{
public:
    cond()
    {
        if (pthread_cond_init(&m_cond, NULL) != 0)
        {
            //pthread_mutex_destroy(&m_mutex);
            throw std::exception();
        }
    }
    ~cond()
    {
        pthread_cond_destroy(&m_cond);
    }
    bool wait(pthread_mutex_t *m_mutex)
    {
        int ret = 0;
        //pthread_mutex_lock(&m_mutex);
        ret = pthread_cond_wait(&m_cond, m_mutex);
        //pthread_mutex_unlock(&m_mutex);
        return ret == 0;
    }
    bool timewait(pthread_mutex_t *m_mutex, struct timespec t)
    {
        int ret = 0;
        //pthread_mutex_lock(&m_mutex);
        ret = pthread_cond_timedwait(&m_cond, m_mutex, &t);
        //pthread_mutex_unlock(&m_mutex);
        return ret == 0;
    }
    bool signal()
    {
        return pthread_cond_signal(&m_cond) == 0;
    }
    bool broadcast()
    {
        return pthread_cond_broadcast(&m_cond) == 0;
    }

private:
    //static pthread_mutex_t m_mutex;
    pthread_cond_t m_cond;
};
#endif

互斥锁和信号量是简单的封装,而对于条件变量作者注释掉了互斥锁,但并不会影响互斥访问,因为作者选择用封装好的互斥锁并且在外部来使用。例如在block_queue.h这个文件中,作者将locker m_mutex;作为私有数据成员,并通过get函数获得该锁。文章来源地址https://www.toymoban.com/news/detail-729122.html

template <class T>
class block_queue
{
public:
    ...
    if (!m_cond.timewait(m_mutex.get(), t))
    {
        m_mutex.unlock();
        return false;
    }
    ...
private:
    locker m_mutex;
    ...
}

到了这里,关于TinyWebServer学习笔记-互斥锁、信号量、条件变量的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • FreeRTOS源码分析-10 互斥信号量

    目录   1 事件标志组概念及其应用 1.1 事件标志组定义 1.2 FreeRTOS事件标志组介绍 1.3 FreeRTOS事件标志组工作原理 2 事件标志组应用 2.1 功能需求 2.2 API  2.3 功能实现 3 事件标志组原理 3.1 事件标志组控制块 3.2 事件标志组获取标志位 3.3 等待事件标志触发 3.4 事件标志组设置标志

    2024年02月14日
    浏览(43)
  • 【系统编程】线程安全(POSIX信号量、互斥锁、读写锁等)

    (꒪ꇴ꒪ ),Hello我是 祐言QAQ 我的博客主页:C/C++语言,数据结构,Linux基础,ARM开发板,网络编程等领域UP🌍 快上🚘,一起学习,让我们成为一个强大的攻城狮! 送给自己和读者的一句鸡汤🤔: 集中起来的意志可以击穿顽石! 作者水平很有限,如果发现错误,请在评论区指

    2024年02月10日
    浏览(67)
  • FreeRTOS的二值信号量和互斥量之间的区别和联系

    目录 1. 二值信号量和互斥量的作用 1.1 二值信号量的作用 1.2 互斥量的作用 2. FreeRTOS二值信号量和互斥锁关系 2.1 不同点 2.2 相同点 3. 如何选择 3.1 根据场景选择合适的同步机制 3.2 根据优先级设计同步机制 FreeRTOS是一款广泛应用于嵌入式系统中的实时操作系统,其中信号量(

    2024年02月06日
    浏览(41)
  • 二、操作系统进程管理(10)——用信号量机制实现进程互斥、同步、前驱关系

        (1)分析并发进程的关键活动,划定临界区。(如对临界区资源打印机的访问就应放在临界区)     (2)设置互斥信号量mutex,初值为1。     (3)在临界区之前执行P(mutex)。      //即使用资源前先申请(P操作)     (4)在临界区之后执行V(mutex)。     (5)对不

    2023年04月08日
    浏览(43)
  • STM32 CubeMX (第二步Freertos任务通信:队列、信号量、互斥量,事件组,任务通知)

    学习使用Freertos第二步 在 FreeRTOS 中,任务通信可以通过以下函数来实现: xQueueCreate() :用于创建一个消息队列。可以设置队列长度和每个消息的大小。 xQueueSend() :将一条消息发送到队列中。可以选择阻塞或非阻塞发送。 xQueueReceive() :从队列中接收一条消息。可以选择阻塞

    2024年02月11日
    浏览(45)
  • 【Linux】详解进程通信中信号量的本质&&同步和互斥的概念&&临界资源和临界区的概念

             访问资源在安全的前提下,具有一定的顺序性,就叫做同步 。在多道程序系统中,由于资源有限,进程或线程之间可能产生冲突。同步机制就是为了解决这些冲突,保证进程或线程之间能够按照既定的顺序访问共享资源。同步机制有助于避免竞态条件和死锁(

    2024年04月25日
    浏览(46)
  • 【小黑嵌入式系统第十二课】μC/OS-III程序设计基础(二)——系统函数使用场合、时间管理、临界区管理、使用规则、互斥信号量

    上一课: 【小黑嵌入式系统第十一课】μC/OS-III程序设计基础(一)——任务设计、任务管理(创建基本状态内部任务)、任务调度、系统函数 下一课: 【小黑嵌入式系统第十三课】PSoC 5LP第二个实验——中断控制实验 1.1 时间管理 1.1.1 控制任务的执行周期 在任务函数的代码

    2024年02月04日
    浏览(57)
  • 【STM32】FreeRTOS消息队列和信号量学习

    一、消息队列(queue) 队列是一种用于实现任务与任务之间,任务与中断之间消息交流的机制。 注意:1.数据的操作是FIFO模式。 2.队列需要明确数据的大小和队列的长度。 3.写和读都会出现堵塞。 实验:创建一个消息队列,两个发送任务,一个接收任务。 其中任务一任务三

    2024年02月13日
    浏览(41)
  • RT_Thread内核机制学习(六)信号量

    要传输较大数据时,使用队列。 传输较小数值时,使用邮箱。 队列、邮箱用来传递数据。 如果只是用来传递资源的个数,可以使用信号量。 A车与B车只需要传递信号量(代表资源)。 获取信号量 如果value0,value–,return OK;如果value 0,timeout 0,return -ETIMEOUT;如果value==0,ti

    2024年02月10日
    浏览(33)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包