当前位置: 首页 > news >正文

嵌入式学习之系统编程(七)线程的控制(互斥与同步)和死锁

目录

一、线程的互斥

(一)实例引入

(二)概念

(三)互斥锁相关函数

1、定义锁:pthread_mutex_t mutex;

2、初始化锁函数:pthread_mutex_init();

3、加锁:pthread_mutex_lock();

4、解锁:pthread_mutex_unlock();

5、销毁:pthread_mutex_destroy();

6、非阻塞锁:pthread_mutex_trylock();

7、注意事项

8、示例

9、练习

二、线程的同步

(一)概念

(二)信号量相关函数

1、定义信号量:sem_t sem;

2、初始化信号量:sem_init();

3、申请信号量(P操作):sem_wait();

4、释放信号量(V操作):sem_post();

5、销毁:sem_destroy();

6、信号量的两种用法示例

(1)同步(互斥+顺序):二值信号量

(2)互斥:计数信号量

三、死锁

1、死锁定义

2、产生死锁的原因

3、产生死锁的四个必要条件(面问)

扩:typedef三种用法(简化代码编写)

一、线程的互斥

(一)实例引入

1、示例:

运行结果

两个线程都在运行,出现问题原因:资源竞争(对全局变量都进行了读写操作)

2、扩展:

注:reg 寄存器,暂存;alu 逻辑计算单元

(1)读数据

(2)计算

(3)写数据

(二)概念

1、互斥:在多线程中对临界资源的排他性访问。

        临界资源:公共操作的东西(可为变量、设备);

        排他性访问:多线程在同一时刻只能有一个线程进行读或写操作。

2、互斥锁:保证临界资源的访问控制(锁在系统中本质是结构体)

     使用步骤:     定义互斥锁 ——>初始化锁 ——>加锁 ——>解锁 ——>销毁

        (1)向系统申请锁mutex(在pcb块)约定1没锁,0锁了

        (2)初始化锁

        (3)尝试使用该资源,申请到后用的时候加锁(其它线程要使用该资源尝试解

                锁,解不开锁则进入休眠等待状态)

        (4)用完后解锁释放资源,系统通知,两个线程再次同时竞争资源

        (5)不需要互斥操作后销毁锁

(三)互斥锁相关函数

1、定义锁:pthread_mutex_t mutex;

(1)pthread_mutex_t :互斥锁类型        

(2) mutex:互斥锁变量(创建在pcb块中的东西) 也称内核对象(在内核中被定义

                        的)

2、初始化锁函数:pthread_mutex_init();

(1)函数原型:

int pthread_mutex_init(pthread_mutex_t *mutex,const pthread_mutexattr_t *attr);

(2)功能:将已经定义好的互斥锁初始化。

(3)参数:mutex 要初始化的互斥锁

                   atrr  初始化的值,一般是NULL表示默认锁

(4)返回值:成功 0;失败 非零

3、加锁:pthread_mutex_lock();

(1)函数原型:int pthread_mutex_lock(pthread_mutex_t *mutex);

(2)功能:用指定的互斥锁开始加锁代码

  加锁后的代码到解锁部分的代码属于原子操作(汇编角度来说多个语句一把走完)
  在加锁期间其他进程/线程都不能操作该部分代码
  如果该函数在执行的时候,mutex已经被其他部分使用则代码阻塞。

(3)参数: mutex 用来给代码加锁的互斥锁

(4)返回值:成功 0;失败 非零

4、解锁:pthread_mutex_unlock();

(1)函数原型:int pthread_mutex_unlock(pthread_mutex_t *mutex);

(2)功能:将指定的互斥锁解锁。

        解锁之后代码不再排他访问,一般加锁解锁同时出现。

(3)参数:用来解锁的互斥锁

(4)返回值:成功 0;失败 非零

(5)注:解锁之后代码不再排他访问,一般加锁解锁同时出现。

5、销毁:pthread_mutex_destroy();

(1)函数原型: int pthread_mutex_destroy(pthread_mutex_t *mutex);

(2) 功能:使用互斥锁完毕后需要销毁互斥锁

(3) 参数:mutex 要销毁的互斥锁

(4)返回值:成功  0; 失败  非零

6、非阻塞锁:pthread_mutex_trylock();

(1)函数原型:int pthread_mutex_trylock(pthread_mutex_t *mutex);

(2)功能:类似加锁函数效果,唯一区别就是不阻塞(稍后再试),非阻塞锁,CPU

                     占有率较高

(3)参数:mutex 用来加锁的互斥锁

(4)返回值:成功 0(操作临界资源);非0(稍后再试)

        判断返回值状态(申请成功与否),外加while(1)

(5)适用于有多个资源的情况,一般用阻塞锁居多。

7、注意事项

(1)上互斥锁的地方不并发;

(2)被保护的临界资源要尽可能小(不要大递归、不要sleep)

8、示例

运行结果

9、练习

#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>

pthread_mutex_t mutex;//定义锁
int WIN=3;

void* th(void* arg)
{
    while(1)
    {
        pthread_mutex_lock(&mutex);//加锁
        if(WIN>0)
        {
            WIN--;
             printf("get win\n");
            pthread_mutex_unlock(&mutex);//解锁
            
            int n = rand() % 5 + 1;//随机数
            sleep(n);

            pthread_mutex_lock(&mutex);//加锁
            WIN++;
            printf("relese win");
            pthread_mutex_unlock(&mutex);//解锁
            break;
        }
        else
        {
            pthread_mutex_unlock(&mutex);//解锁,不解锁会发生死锁
        }
    }
    return NULL;
}

int    main(int argc, char **argv)
{
    
    pthread_t tid[10]={0};
    int i = 0;

    pthread_mutex_init(&mutex,NULL);//初始化锁
    for(i = 0 ;i<10;i++)
    {
        pthread_create(&tid[i],NULL,th,NULL);
    }

    for(i = 0 ;i<10;i++)
    {

        pthread_join(tid[i],NULL);
    }
    pthread_mutex_destroy(&mutex);//销毁锁
    system("pause");
    return 0;

二、线程的同步

(一)概念

1、定义:有一定先后顺序的对资源的排他性访问;(同步:互斥的基础上加上顺序)

     同步原因:互斥锁可以控制排他访问但没有次序。

2、信号量(本质是结构体):锁的一种

  步骤:信号量的定义 ——>信号量的初始化 ——>信号量的PV操作——>信号量的销毁

(1)信号量的定义(申请信号量与同步线程的个数相同)

(2)初始化信号量(信号量状态初值:1该走就走;0等待)

(3)执行体操作

(4)释放的是下一个信号量

4、信号量的PV操作

(1)P :申请资源——申请一个二值信号量(值不是1就是0)

(2)V :释放资源——释放一个二值信号量

3、信号量的分类

(1)无名信号量 ——>线程间通信

(2)有名信号量 ——>进程间通信

(二)信号量相关函数

1、定义信号量:sem_t sem;

  sem_t                    sem;
   信号量的类型     信号量的变量

2、初始化信号量:sem_init();

(1)函数原型:int sem_init(sem_t *sem, int pshared, unsigned int value);

(2)功能:将已经定义好的信号量赋值;

(3)参数:sem 要初始化的信号量

                    pshared = 0 (表示线程间使用信号量);

                    pshared != 0 (表示进程间使用信号量);

                    value 信号量的初始值,一般无名信号量都是二值信号量(0 1) :

                                0 表示红灯,进程暂停阻塞;

                                1 表示绿灯,进程可以通过执行;

(4)返回值:成功  0;失败  -1

3、申请信号量(P操作):sem_wait();

(1)函数原型:int sem_wait(sem_t *sem);

(2)功能:判断当前sem信号量是否有资源可用。

                    如果sem有资源(==1),则申请该资源,程序继续运行;

                     如果sem没有资源(==0),则线程阻塞等待,一旦有资源则自动申请资源并

                        继续运行程序。

        注:sem申请资源后会自动执行sem=sem-1;

(3)参数:sem 要判断的信号量资源;

(4)返回值:成功 0 ;失败 -1

4、释放信号量(V操作):sem_post();

(1)函数原型:int sem_post(sem_t *sem);

(2)功能:函数可以将指定的sem信号量资源释放;

                    并默认执行,sem = sem+1;

                    线程在该函数上不会阻塞。

(3)参数:sem 要释放资源的信号量;

(4)返回值:成功 0;失败 -1

5、销毁:sem_destroy();

(1)函数原型: int sem_destroy(sem_t *sem);

(2)功能:使用完毕将指定的信号量销毁;

(3)参数:sem要销毁的信号量;

(4)返回值:成功 0;失败  -1

6、信号量的两种用法示例

(1)同步(互斥+顺序):二值信号量

(2)互斥:计数信号量

资源个数不是1个时可使用

三、死锁

1、死锁定义

        死锁是指多个进程或线程在竞争资源时,由于互相等待对方释放资源而陷入无限阻

塞的状态。(归根结底是逻辑错误导致的)

2、产生死锁的原因

(1) 因为系统资源不足。

(2) 进程运行推进的顺序不合适。

(3) 资源分配不当等。

如果系统资源充足,进程的资源请求都能够得到满足,死锁出现的可能性就很低,否则就会因争夺有限的资源而陷入死锁。其次,进程运行推进顺序与速度不同,也可能产生死锁。

3、产生死锁的四个必要条件(面问)

(1) 互斥条件:一个资源每次只能被一个进程或线程使用。(若死锁可先把阻塞锁换

                                成非阻塞锁找出错误后改回)

(2) 请求与保持条件:一个进程或线程因请求资源而阻塞时,对已获得的资源保持不

                                        放。

(3) 不剥夺条件:进或线程程已获得的资源,在末使用完之前,不能强行剥夺。

(4) 循环等待条件:若干进程或线程之间形成一种头尾相接的循环等待资源关系。

http://www.xdnf.cn/news/702883.html

相关文章:

  • CPG开源项目对比
  • 18度的井水
  • C++补充基础小知识:为什么要继承、什么时候继承、什么时候直接用
  • 高并发计数器LongAdder 实现原理与使用场景详解
  • Jmeter性能测试(应用场景、性能测试流程、搭建测试环境)
  • 实例与选项对象
  • SpringBoot+Vue+Echarts实现可视化图表的渲染
  • 自动生成程序的heap文件
  • #!/usr/bin/env python
  • JS中的属性描述符
  • Day 20
  • 生成式引擎在不同行业的应用案例
  • 第十章 Java基础-Static静态变量
  • 基于物理约束的稀疏IMU运动捕捉系统
  • spring和Mybatis的各种查询
  • Rust 学习笔记:使用迭代器改进 minigrep
  • 力扣刷题Day 61:子集(78)
  • 【案例94】笛卡尔积导致报“临时表空间不足”
  • bat 批处理通过拖拽,来获取拖入文件的信息
  • 【25-cv-00656】Whitewood律所代理Olga Drozdova 蝴蝶版权图维权案
  • 【Web应用】若依框架:基础篇07功能详解-定时任务
  • 不同坐标系下的 面积微元
  • Android-Room + WorkManager学习总结
  • 2G Nand Jlink烧录报错Failed to allocated 0x1B000000 bytes of memory!
  • 5G 核心网中 NRF 网元的功能、接口及参数详解
  • 8.7 使用 EAP-AKA 进行订阅转移
  • 星图云交通综合应用解决方案:破解交通基建抢建拖建、工程量大等难题,赋能智慧交通
  • 2025年5月AI科技领域周报(5.19-5.25):大模型多模态突破 具身智能开启机器人新纪元
  • DockThor: 免费的在线小分子“虚拟筛选”平台
  • 即插即用!全新记忆回溯策略:一种元启发式算法的进化更新机制,含完整免费MATLAB代码