Webserver(3.3)生产者消费者模型

🕗 发布于 2024-11-08 02:57 c++

生产者消费者简单模型

//生产者消费者模型

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

struct Node{
    int num;
    struct Node * next;
};
//头结点
struct Node * head=NULL;

void * producer(void * arg){
    //不断创建新的节点，添加到链表中
    while(1){
        struct Node * newNode=(struct Node *)malloc(sizeof(struct Node));
        newNode->next=head;
        head=newNode;
        newNode->num=rand()%1000;
        printf("add node,num:%d,tid:%ld\n",newNode->num,pthread_self());
        usleep(100);
    }

    return NULL;
}

void * customer(void * arg){
    while(1){
        //保存头结点的指针
        struct Node * tmp=head;
        head = head->next;
        printf("del node;num:%d,tid:%ld\n",tmp->num,pthread_self());
        free(tmp);
        usleep(100);

    }
    return NULL;
}

int main(){

    //创建5个生产者线程，和5个消费者线程
    pthread_t ptids[5],ctids[5];

    for(int i=0;i<5;i++){
        pthread_create(&ptids[i],NULL,producer,NULL);
        pthread_create(&ctids[5],NULL,customer,NULL);
    }

    for(int i=0;i<5;i++){
        pthread_detach(ptids[i]);
        pthread_detach(ctids[5]);
    }

    // while(1){
    //     sleep(10);
    // }

    pthread_exit(NULL);

    return 0;
}

在这里插入图片描述
容易出现段错误，原因就是会有几种情况：
会产生数据安全问题，比如生产者还未生产出来，就去消费。

//生产者消费者模型

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

//创建一个互斥
pthread_mutex_t mutex;

struct Node{
    int num;
    struct Node * next;
};
//头结点
struct Node * head=NULL;

void * producer(void * arg){
    //不断创建新的节点，添加到链表中
    while(1){
        pthread_mutex_lock(&mutex);
        struct Node * newNode=(struct Node *)malloc(sizeof(struct Node));
        newNode->next=head;
        head=newNode;
        newNode->num=rand()%1000;
        printf("add node,num:%d,tid:%ld\n",newNode->num,pthread_self());
        pthread_mutex_unlock(&mutex);
        usleep(100);
    }

    return NULL;
}

void * customer(void * arg){
    while(1){
        //保存头结点的指针
        pthread_mutex_lock(&mutex);
        struct Node * tmp=head;
        //判断是否有数据
        if(head!=NULL){
            //有数据
            head = head->next;
            printf("del node;num:%d,tid:%ld\n",tmp->num,pthread_self());
            free(tmp);
            pthread_mutex_unlock(&mutex);
            usleep(100);
        }else{
            //没有数据
            pthread_mutex_unlock(&mutex);
        }
        

    }
    return NULL;
}

int main(){

    pthread_mutex_init(&mutex,NULL);
    //创建5个生产者线程，和5个消费者线程
    pthread_t ptids[5],ctids[5];


    for(int i=0;i<5;i++){
        pthread_create(&ptids[i],NULL,producer,NULL);
        pthread_create(&ctids[5],NULL,customer,NULL);
    }

    for(int i=0;i<5;i++){
        pthread_detach(ptids[i]);
        pthread_detach(ctids[5]);
    }

    while(1){
        sleep(10);
    }
    pthread_mutex_destroy(&mutex);

    pthread_exit(NULL);


    return 0;
}

解决该问题需要用互斥量确保线程同步，用条件变量或者信号量去解决生产者和消费者之间同步的问题，生产者把数据生产满了要通知消费者去消费。

条件变量

//生产者消费者模型

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

//创建一个互斥
pthread_mutex_t mutex;
//创建条件变量
pthread_cond_t cond;

struct Node{
    int num;
    struct Node * next;
};
//头结点
struct Node * head=NULL;

void * producer(void * arg){
    //不断创建新的节点，添加到链表中
    while(1){
        pthread_mutex_lock(&mutex);
        struct Node * newNode=(struct Node *)malloc(sizeof(struct Node));
        newNode->next=head;
        head=newNode;
        newNode->num=rand()%1000;
        printf("add node,num:%d,tid:%ld\n",newNode->num,pthread_self());
        //只要生产了一个，就通知消费者消费
        pthread_cond_signal(&cond);
        pthread_mutex_unlock(&mutex);
        usleep(100);
    }

    return NULL;
}

void * customer(void * arg){
    while(1){
        //保存头结点的指针
        pthread_mutex_lock(&mutex);
        struct Node * tmp=head;
        //判断是否有数据
        if(head!=NULL){
            //有数据
            head = head->next;
            printf("del node;num:%d,tid:%ld\n",tmp->num,pthread_self());
            
            free(tmp);
            pthread_mutex_unlock(&mutex);
            usleep(100);
        }else{
            //没有数据，需要等待
            //当wait调用阻塞的时候，会对互斥锁进行解锁，当不阻塞的时候，继续向下执行会重新加锁
            pthread_cond_wait(&cond,&mutex);
            pthread_mutex_unlock(&mutex);
        }
        

    }
    return NULL;
}

int main(){

    pthread_mutex_init(&mutex,NULL);
    pthread_cond_init(&cond,NULL);
    //创建5个生产者线程，和5个消费者线程
    pthread_t ptids[5],ctids[5];


    for(int i=0;i<5;i++){
        pthread_create(&ptids[i],NULL,producer,NULL);
        pthread_create(&ctids[5],NULL,customer,NULL);
    }

    for(int i=0;i<5;i++){
        pthread_detach(ptids[i]);
        pthread_detach(ctids[5]);
    }

    while(1){
        sleep(10);
    }
    pthread_mutex_destroy(&mutex);
    pthread_cond_destroy(&cond);

    pthread_exit(NULL);


    return 0;
}

在这里插入图片描述

信号变量

//生产者消费者模型

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

//创建一个互斥
pthread_mutex_t mutex;
//创建两个信号量
sem_t psem;
sem_t csem;

struct Node{
    int num;
    struct Node * next;
};
//头结点
struct Node * head=NULL;

void * producer(void * arg){
    //不断创建新的节点，添加到链表中
    while(1){
        sem_wait(&psem);
        pthread_mutex_lock(&mutex);
        struct Node * newNode=(struct Node *)malloc(sizeof(struct Node));
        newNode->next=head;
        head=newNode;
        newNode->num=rand()%1000;
        printf("add node,num:%d,tid:%ld\n",newNode->num,pthread_self());
        
        pthread_mutex_unlock(&mutex);
        sem_post(&csem);
        usleep(100);
    }

    return NULL;
}

void * customer(void * arg){
    while(1){
        sem_wait(&csem);
        //保存头结点的指针
        pthread_mutex_lock(&mutex);
        struct Node * tmp=head;

        head = head->next;
        printf("del node;num:%d,tid:%ld\n",tmp->num,pthread_self());
        
        free(tmp);
        pthread_mutex_unlock(&mutex);
        sem_post(&psem);
        
        

    }
    return NULL;
}

int main(){

    pthread_mutex_init(&mutex,NULL);
    sem_init(&psem,0,8);
    sem_init(&csem,0,0);
    //创建5个生产者线程，和5个消费者线程
    pthread_t ptids[5],ctids[5];


    for(int i=0;i<5;i++){
        pthread_create(&ptids[i],NULL,producer,NULL);
        pthread_create(&ctids[5],NULL,customer,NULL);
    }

    for(int i=0;i<5;i++){
        pthread_detach(ptids[i]);
        pthread_detach(ctids[5]);
    }

    while(1){
        sleep(10);
    }
    pthread_mutex_destroy(&mutex);


    pthread_exit(NULL);


    return 0;
}

在这里插入图片描述

原文地址：https://blog.csdn.net/qq_43920838/article/details/143504193

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：【ORACLE】对Oracle中char类型的研究分析
下一篇：SQL练习专场--01

【信号处理】使用CNN对RF调制信号进行分类
Using CNN to classify RF modulation data.Dataset is from: DATA LINKpaper: Over the Air Deep Learning
阅读更多2024-11-08
MYSQL学习笔记（二）--认识索引、使用索引、索引失效
索引（index）是帮助MySQL高效获取数据的数据结构(有序)。在数据之外，数据库系统还维护着满足特定查找算法的数据结构，这些数据结构以某种方式引用（指向）数据，这样就可以在这些数据结构上实现高级
阅读更多2024-11-08
SpringCloud Sentinel 服务治理详解
这篇文章，根据这篇文章流控规则可以完美的实现效果，但是其他的授权规则、系统规则小编试了好像业务并不生效，主要是格式的问题，有兴趣的可以自行研究一下，另外一种办法就是自己写业务逻辑实现Nacos规则拉取
阅读更多2024-11-08
ffmpeg 视频滤镜：屏蔽边框杂色- fillborders
fillborders滤镜有几种方式帮你屏蔽边框的杂色、不好的图案。可以看到图片的上边和下边有黄色的杂色。设置fixed模式的填充颜色。设置fade模式的填充颜色。
阅读更多2024-11-08
使用 FFmpeg 进行音视频转换的相关命令行参数解释
FFmpeg 是一个强大的多媒体框架，能够解码、编码、转码、录制、播放以及流化几乎所有类型的音频和视频。目前有很多音视频或播放器都是基于 FFmpeg 开发的，如果你想快速且批量的处理音频或视频，这里
阅读更多2024-11-08
JVM垃圾回收详解
当垃圾回收器准备回收一个对象时，如果发现它还有虚引用，就会在回收对象的内存之前，把这个虚引用加入到与之关联的引用队列中。在垃圾回收器线程扫描它所管辖的内存区域的过程中，一旦发现了只具有弱引用的对象，不
阅读更多2024-11-08
CSRA2的LINUX操作系统24年11月2日上午上课笔记
local：他会将linux中的所有文件的路径信息保存到数据库中，在数据库中查找文件。# find . -type f # 查找当前目录下所有文件类型是普通文件的文件。# nc:n字节 nk:
阅读更多2024-11-08
阿里云 DataWorks 正式支持 SelectDB & Apache Doris 数据源，实现 MySQL 整库实时同步
以上即为将 MySQL 整库实时同步至 SelectDB Cloud 的具体操作步骤。通过使用 Dataworks，您能够高效地将 MySQL 数据库同步至 SelectDB Enterprise、S
阅读更多2024-11-08
基于SSM（Spring + Spring MVC + MyBatis）框架的快递管理系统
用户管理：管理员可以添加、删除、修改和查询用户信息。快递员管理：记录快递员信息，如姓名、联系方式、所属区域等。客户管理：记录客户信息，如姓名、联系方式、地址等。包裹管理：支持对包裹信息的增删改查操作，
阅读更多2024-11-08
OpenCV自学系列（1）——简介和GUI特征操作
对应第一章#简单介绍基于OpenCV-python的官方文档进行opencv自学##其原文为可见，即使OpenCV版本已经4.x，但官方给出的教程还是3.x,此教程还是以最新版4.10做学习。##环境
阅读更多2024-11-08

Webserver(3.3)生产者消费者模型

目录

生产者消费者简单模型

条件变量

信号变量

相关文章