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

C语言队列操作及其安全问题

在C语言中,队列是一种常用的数据结构,特别适用于嵌入式开发中的任务调度、缓冲区管理等场景。下面是一个简单的循环队列的模板代码,它使用数组来实现队列,并提供了基本的入队(enqueue)和出队(dequeue)操作。

示例代码如下:

#include <stdio.h>

#include <stdbool.h>

#include <string.h>

 

#define QUEUE_MAX_SIZE 10 // 定义队列的最大容量

 

// 队列的结构体定义

typedef struct {

    int data[QUEUE_MAX_SIZE]; // 存储队列元素的数组(如果需要动态扩展队列容量,可以考虑使用链表来实现队列)

    int front; // 队列头部的索引

    int rear; // 队列尾部的索引

} Queue;

 

// 初始化队列

void queueInit(Queue *q) {

    q->front = q->rear = 0;

}

 

// 判断队列是否为空

bool isQueueEmpty(Queue *q) {

    return q->front == q->rear;

}

 

// 判断队列是否已满

bool isQueueFull(Queue *q) {

    return (q->rear + 1) % QUEUE_MAX_SIZE == q->front;

}

 

// 入队操作

bool enqueue(Queue *q, int value) {

    if (isQueueFull(q)) {

        return false; // 队列已满,无法入队

    }

    q->data[q->rear] = value;

    q->rear = (q->rear + 1) % QUEUE_MAX_SIZE;

    return true;

}

 

// 出队操作

bool dequeue(Queue *q, int *value) {

    if (isQueueEmpty(q)) {

        return false; // 队列为空,无法出队

    }

    *value = q->data[q->front];

    q->front = (q->front + 1) % QUEUE_MAX_SIZE;

    return true;

}

 

// 打印队列中的所有元素

void printQueue(Queue *q) {

    int i = q->front;

    for (int count = 0; count < (q->rear - q->front + QUEUE_MAX_SIZE) % QUEUE_MAX_SIZE; count++) {

        printf("%d ", q->data[i]);

        i = (i + 1) % QUEUE_MAX_SIZE;

    }

    printf("\n");

}

 

// 主函数,演示队列的使用

int main() {

    Queue q;

    queueInit(&q);

 

    // 入队操作

    enqueue(&q, 1);

    enqueue(&q, 2);

    enqueue(&q, 3);

 

    // 打印队列

    printf("Queue after enqueue: ");

    printQueue(&q);

 

    // 出队操作

    int value;

    dequeue(&q, &value);

    printf("Dequeued value: %d\n", value);

 

    // 再次打印队列

    printf("Queue after dequeue: ");

    printQueue(&q);

 

    return 0;

}

这段代码定义了一个队列结构体,包括一个整型数组来存储队列元素,以及两个索引来分别表示队列的头部和尾部。 enqueue  函数用于在队列尾部添加元素, dequeue  函数用于从队列头部移除元素。 isQueueEmpty  和  isQueueFull  函数分别用于检查队列是否为空或满。

但是,这个队列实现是线程不安全的。在多线程环境中使用时,需要添加适当的同步机制来避免竞态条件。

考虑引入同步机制,帮助解决上述队列实现中的不安全问题:


1.互斥锁(Mutex): 互斥锁是一种基本的同步机制,用于保护共享资源不被多个线程同时访问。在队列操作中,可以在入队和出队操作前后使用互斥锁来确保每次只有一个线程可以修改队列。
#include <pthread.h>

pthread_mutex_t queue_mutex = PTHREAD_MUTEX_INITIALIZER;

bool enqueue(Queue *q, int value) {
    pthread_mutex_lock(&queue_mutex);
    if (isQueueFull(q)) {
        pthread_mutex_unlock(&queue_mutex);
        return false;
    }
    q->data[q->rear] = value;
    q->rear = (q->rear + 1) % QUEUE_MAX_SIZE;
    pthread_mutex_unlock(&queue_mutex);
    return true;
}

bool dequeue(Queue *q, int *value) {
    pthread_mutex_lock(&queue_mutex);
    if (isQueueEmpty(q)) {
        pthread_mutex_unlock(&queue_mutex);
        return false;
    }
    *value = q->data[q->front];
    q->front = (q->front + 1) % QUEUE_MAX_SIZE;
    pthread_mutex_unlock(&queue_mutex);
    return true;
}
2.条件变量(Condition Variable): 条件变量可以与互斥锁一起使用,以实现更高级的同步机制。它们允许线程在某些条件不满足时挂起,直到其他线程发出信号。
#include <pthread.h>

pthread_mutex_t queue_mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t queue_not_full = PTHREAD_COND_INITIALIZER;
pthread_cond_t queue_not_empty = PTHREAD_COND_INITIALIZER;

bool enqueue(Queue *q, int value) {
    pthread_mutex_lock(&queue_mutex);
    while (isQueueFull(q)) {
        pthread_cond_wait(&queue_not_full, &queue_mutex);  // 等待队列有空间
    }
    q->data[q->rear] = value;
    q->rear = (q->rear + 1) % QUEUE_MAX_SIZE;
    pthread_cond_signal(&queue_not_empty);  // 通知可能有线程在等待出队
    pthread_mutex_unlock(&queue_mutex);
    return true;
}

bool dequeue(Queue *q, int *value) {
    pthread_mutex_lock(&queue_mutex);
    while (isQueueEmpty(q)) {
        pthread_cond_wait(&queue_not_empty, &queue_mutex);  // 等待队列中有元素
    }
    *value = q->data[q->front];
    q->front = (q->front + 1) % QUEUE_MAX_SIZE;
    pthread_cond_signal(&queue_not_full);  // 通知可能有线程在等待入队
    pthread_mutex_unlock(&queue_mutex);
    return true;
}
3.读写锁(Read-Write Lock): 如果队列的读操作远多于写操作,使用读写锁可以提高性能。读写锁允许多个读操作同时进行,但写操作会独占锁。
#include <pthread.h>

pthread_rwlock_t queue_rwlock = PTHREAD_RWLOCK_INITIALIZER;

bool enqueue(Queue *q, int value) {
    pthread_rwlock_wrlock(&queue_rwlock);
    if (isQueueFull(q)) {
        pthread_rwlock_unlock(&queue_rwlock);
        return false;
    }
    // ... 入队操作
    pthread_rwlock_unlock(&queue_rwlock);
    return true;
}

bool dequeue(Queue *q, int *value) {
    pthread_rwlock_wrlock(&queue_rwlock);
    if (isQueueEmpty(q)) {
        pthread_rwlock_unlock(&queue_rwlock);
        return false;
    }
    // ... 出队操作
    pthread_rwlock_unlock(&queue_rwlock);
    return true;
}

void printQueue(Queue *q) {
    pthread_rwlock_rdlock(&queue_rwlock);
    // ... 打印队列操作
    pthread_rwlock_unlock(&queue_rwlock);
}
4.原子操作: 某些编译器或硬件平台提供了原子操作,可以直接在不使用锁的情况下保证操作的原子性。这可以减少锁的开销,但通常只适用于简单的操作。


最后,需要注意,使用这些同步机制时,需要确保正确地初始化和销毁它们,并且在适当的时候获取和释放锁。同时,还需要考虑死锁的可能性,并采取相应的预防措施。
 

 

 

 

 

相关文章:

C语言队列操作及其安全问题

在C语言中&#xff0c;队列是一种常用的数据结构&#xff0c;特别适用于嵌入式开发中的任务调度、缓冲区管理等场景。下面是一个简单的循环队列的模板代码&#xff0c;它使用数组来实现队列&#xff0c;并提供了基本的入队&#xff08;enqueue&#xff09;和出队&#xff08;de…...

next.js v14 升级全步骤|迁移 pages Router 到 App Router

【概括】本文升级整体按照官网文档指引进行&#xff0c;在迁移 pages Router 前先看了官网的实操视频。 【注意】文章内对 .babel.ts、next.config.js 进行了多次更改&#xff0c;最终配置可见 报错3: Server Error ReferenceError: React is not defined 一、升级 Next.js 版…...

如何在Ubuntu上安装WordPress

如何在Ubuntu上安装WordPress 执行系统更新 apt update && apt upgrade第一步 安装 Apache apt install apache2确认 Apache 安装是否成功. systemctl status apache2安装成功后 打开浏览器输入 http://server-ip-address 第二步 安装 MySQL apt install mariad…...

处理导入Excel文件过大导致Zip bomb detected的问题

处理导入Excel文件过大导致Zip bomb detected的问题 处理导入Excel文件过大导致Zip bomb detected的问题解决方案完整示例代码处理内存溢出问题优化处理大文件的策略 处理导入Excel文件过大导致Zip bomb detected的问题 在Java应用中导入Excel文件时&#xff0c;可能会遇到文件…...

【FFmpeg】AVIOContext结构体

【FFmpeg】AVIOContext结构体 1.AVIOContext结构体的定义 参考&#xff1a; FFMPEG结构体分析&#xff1a;AVIOContext 示例工程&#xff1a; 【FFmpeg】调用ffmpeg库实现264软编 【FFmpeg】调用ffmpeg库实现264软解 【FFmpeg】调用ffmpeg库进行RTMP推流和拉流 【FFmpeg】调用…...

Python控制结构

文章目录 控制结构1. 条件语句1.1 if语句1.2 elif语句1.3 else 语句 2. 循环语句2.1 for循环2.2 while循环 控制循环的语句3.1 break语句3.2 continue语句3.3 else语句与循环配合 控制结构 Python中的控制结构是指管理代码执行流程的语句和机制&#xff0c;包括条件语句、循环…...

OpenCV--图形轮廓

图形轮廓 图像轮廓查找轮廓绘制轮廓计算轮廓的面积和周长多边形逼近与凸包外接矩形 图像轮廓 import cv2 import numpy as np""" 图形轮廓--具有相同颜色或灰度的连续点的曲线 用于图形分析和物体的识别和检测 注意&#xff1a;为了检测的准确性&#xff0c;必…...

MYSQL通过EXPLAIN关键字来分析SQL查询的执行计划,判断是否命中了索引

在MySQL中&#xff0c;你可以通过EXPLAIN关键字来分析SQL查询的执行计划&#xff0c;从而判断是否命中了索引。 准备查询语句&#xff1a; 首先&#xff0c;你需要一个带有WHERE子句的SELECT查询&#xff0c;因为WHERE子句中的条件通常与索引相关联。例如&#xff1a; SELECT …...

clean code-代码整洁之道 阅读笔记(第十二章)

第十二章 系统 12.1 通过选进设计达到整洁目的 Kent Beck关于简单设计的四条规则&#xff0c;对于创建具有良好设计的软件有着莫大的帮助。 据Kent所述&#xff0c;只要遵循以下规则&#xff0c;设计就能变得"简单"&#xff1a;运行所有测试&#xff1b;不可重复&…...

FFmpeg YUV编码为H264

使用FFmpeg库把YUV420P文件编码为H264文件&#xff0c;FFmpeg版本为4.4.2-0。 需要yuv测试文件的&#xff0c;可以从我上传的MP4文件中用ffmpeg提取&#xff0c;命令如下&#xff1a; ffmpeg -i <input.mp4> -pix_fmt yuv420p <output.yuv> 代码如下&#xff1a;…...

【C语言】顺序表(上卷)

什么是数据结构&#xff1f; 数据结构是由“数据”和“结构”两词组合而来的。 数据需要管理。数据结构就是计算机存储、组织数据的方式。比如一个班级就是一个结构&#xff0c;管理的就是班级里的学生。如果我们要找三年2班的同学李华&#xff0c;就可以直接去三年2班找而不…...

Luma AI如何注册:文生视频领域的新星

文章目录 Luma AI如何注册&#xff1a;文生视频领域的新星一、Luma 注册方式二、Luma 的效果三、Luma 的优势四、Luma 的功能总结 Luma AI如何注册&#xff1a;文生视频领域的新星 近年来&#xff0c;Luma AI 凭借其在文生视频领域的创新技术&#xff0c;逐渐成为行业的新星。…...

一站式实时数仓Hologres整体能力介绍

讲师&#xff1a;阿里云Hologres PD丁烨 一、产品定位 随着技术的进步&#xff0c;大数据正从规模化转向实时化处理。用户对传统的T1分析已不满足&#xff0c;期望获得更高时效性的计算和分析能力。例如实时大屏&#xff0c;城市大脑的交通监控、风控和实时的个性化推荐&…...

如何在 Windows 上安装 Docker Desktop

如何在 Windows 上安装 Docker Desktop Docker 是一个开放平台&#xff0c;用于开发、部署和运行应用程序。Docker Desktop 是 Docker 在 Windows 和 macOS 上的官方客户端&#xff0c;它使得开发者能够轻松地在本地环境中构建、运行和共享容器化应用程序。本文将详细介绍如何…...

WPF由文本框输入的内容动态渲染下拉框

在做项目过程中&#xff0c;需要扫码枪扫描快递单号或者手动输入快递单号时&#xff0c;自动检索该单号是哪个快递公司的&#xff0c;下拉框中自动带出该单号的快递公司。当输入的快递单号不存在时&#xff0c;将数据库中所有快递公司都带出 效果&#xff1a; 通过输入的快递单…...

RPCMon:一款基于ETW的RPC监控工具

关于RPCMon RPCMon是一款基于事件跟踪的WindowsRPC监控工具&#xff0c;该工具是一款GUI工具&#xff0c;可以帮助广大研究人员通过ETW&#xff08;Event Tracing for Windows&#xff09;扫描RPC通信。 RPCMon能够为广大研究人员提供进程之间RPC通信的高级视图&#xff0c;该…...

【odoo】常用的字符转义:“>“,“<“,““,“/“等

概要 字符转义是指在编写代码或处理文本数据时&#xff0c;将特殊字符转换为另一种形式&#xff0c;以便在特定的上下文中正确解析和处理这些字符。 内容 特殊字符描述XML转义表示法&和符号&amp;<小于符号<>大于符号>"双引号&quot;单引号&ap…...

李宏毅深度学习项目——HW1个人笔记

视频链接 PDF链接 googleColab链接 GoogleColab是一个免费的jupyter notebook&#xff0c;可以用上面的gpu资源进行训练 题目 通过前两天的数据&#xff0c;预测第三天某个人感染新冠的概率 范例 导包 # Numerical Operations import math import numpy as np# Reading/Wr…...

3D Gaussian Splatting Windows安装

0.安装C++ 编译器 https://aka.ms/vs/17/release/vs_buildtools.exe 1.下载源码 git clone https://github.com/graphdeco-inria/gaussian-splatting --recursive 2.安装cuda NVIDIA GPU Computing Toolkit CUDA Toolkit Archive | NVIDIA Developer 3.安装COLMAP...

人脸识别——可解释的人脸识别(XFR)人脸识别模型是根据什么来识别个人的

可解释性人脸识别&#xff08;XFR&#xff09;&#xff1f; 人脸识别有一个任务叫1:N&#xff08;识别&#xff09;。这个任务将一个人的照片与N张注册照片进行比较&#xff0c;找出相似度最高的人。 这项任务用于刑事调查和出入境点。在犯罪调查中&#xff0c;任务从监控摄像…...

<6>-MySQL表的增删查改

目录 一&#xff0c;create&#xff08;创建表&#xff09; 二&#xff0c;retrieve&#xff08;查询表&#xff09; 1&#xff0c;select列 2&#xff0c;where条件 三&#xff0c;update&#xff08;更新表&#xff09; 四&#xff0c;delete&#xff08;删除表&#xf…...

Mybatis逆向工程,动态创建实体类、条件扩展类、Mapper接口、Mapper.xml映射文件

今天呢&#xff0c;博主的学习进度也是步入了Java Mybatis 框架&#xff0c;目前正在逐步杨帆旗航。 那么接下来就给大家出一期有关 Mybatis 逆向工程的教学&#xff0c;希望能对大家有所帮助&#xff0c;也特别欢迎大家指点不足之处&#xff0c;小生很乐意接受正确的建议&…...

Qt Http Server模块功能及架构

Qt Http Server 是 Qt 6.0 中引入的一个新模块&#xff0c;它提供了一个轻量级的 HTTP 服务器实现&#xff0c;主要用于构建基于 HTTP 的应用程序和服务。 功能介绍&#xff1a; 主要功能 HTTP服务器功能&#xff1a; 支持 HTTP/1.1 协议 简单的请求/响应处理模型 支持 GET…...

【2025年】解决Burpsuite抓不到https包的问题

环境&#xff1a;windows11 burpsuite:2025.5 在抓取https网站时&#xff0c;burpsuite抓取不到https数据包&#xff0c;只显示&#xff1a; 解决该问题只需如下三个步骤&#xff1a; 1、浏览器中访问 http://burp 2、下载 CA certificate 证书 3、在设置--隐私与安全--…...

【碎碎念】宝可梦 Mesh GO : 基于MESH网络的口袋妖怪 宝可梦GO游戏自组网系统

目录 游戏说明《宝可梦 Mesh GO》 —— 局域宝可梦探索Pokmon GO 类游戏核心理念应用场景Mesh 特性 宝可梦玩法融合设计游戏构想要素1. 地图探索&#xff08;基于物理空间 广播范围&#xff09;2. 野生宝可梦生成与广播3. 对战系统4. 道具与通信5. 延伸玩法 安全性设计 技术选…...

AspectJ 在 Android 中的完整使用指南

一、环境配置&#xff08;Gradle 7.0 适配&#xff09; 1. 项目级 build.gradle // 注意&#xff1a;沪江插件已停更&#xff0c;推荐官方兼容方案 buildscript {dependencies {classpath org.aspectj:aspectjtools:1.9.9.1 // AspectJ 工具} } 2. 模块级 build.gradle plu…...

稳定币的深度剖析与展望

一、引言 在当今数字化浪潮席卷全球的时代&#xff0c;加密货币作为一种新兴的金融现象&#xff0c;正以前所未有的速度改变着我们对传统货币和金融体系的认知。然而&#xff0c;加密货币市场的高度波动性却成为了其广泛应用和普及的一大障碍。在这样的背景下&#xff0c;稳定…...

智能AI电话机器人系统的识别能力现状与发展水平

一、引言 随着人工智能技术的飞速发展&#xff0c;AI电话机器人系统已经从简单的自动应答工具演变为具备复杂交互能力的智能助手。这类系统结合了语音识别、自然语言处理、情感计算和机器学习等多项前沿技术&#xff0c;在客户服务、营销推广、信息查询等领域发挥着越来越重要…...

【LeetCode】算法详解#6 ---除自身以外数组的乘积

1.题目介绍 给定一个整数数组 nums&#xff0c;返回 数组 answer &#xff0c;其中 answer[i] 等于 nums 中除 nums[i] 之外其余各元素的乘积 。 题目数据 保证 数组 nums之中任意元素的全部前缀元素和后缀的乘积都在 32 位 整数范围内。 请 不要使用除法&#xff0c;且在 O…...

若依登录用户名和密码加密

/*** 获取公钥&#xff1a;前端用来密码加密* return*/GetMapping("/getPublicKey")public RSAUtil.RSAKeyPair getPublicKey() {return RSAUtil.rsaKeyPair();}新建RSAUti.Java package com.ruoyi.common.utils;import org.apache.commons.codec.binary.Base64; im…...