美文网首页
生产者-消费者(计数)

生产者-消费者(计数)

作者: 织田茄子 | 来源:发表于2019-05-22 21:18 被阅读0次

计数信号量相对互斥锁 的优点:

1,不会出现反复无效解锁,信号量就代表实际的产品空间数量,而不是不管三七二十一先上锁再判断;
2,提高了效率,只要一方一提供资源,另一方马上就可以解锁,响应度更高

1 有两个信号量,要用setall,不是setval

        int ret =semctl(semid,0,SETALL,a);//xx1

2 要while循环不然走一轮就结束了;

另外,还有个容易错的,是信号量的数值是unsigned short不是int!!!

 unsigned short a[2]={10,0};

3 被坑最多的,就是信号量结构体写错。要么写重复了,要么就是格式不对,特别是写重了,用接口判断不出bug

                sopv.sem_num= 0;//xx3  not sopp.sem_num
                sopv.sem_op = 1;//xx3 not sopv.op   not sopv.sem_num

4 sleep1,2,不能反了,不然打印的结果会很懵逼,因为产品多,那就消费者多一点


```
#include <func.h>

int main(){
        int semid=semget(10,2,0600|IPC_CREAT);
        ERROR_CHECK(semid,-1,"semget");
        unsigned short a[2]={10,0};// 0 for food 1 for space
        int ret =semctl(semid,0,SETALL,a);//xx1
        ERROR_CHECK(ret,-1,"semctl");
        if(!fork()){//cus
                struct sembuf sopp,sopv;
                sopp.sem_num = 0;
                sopp.sem_op = -1;
                sopp.sem_flg = SEM_UNDO;
                sopv.sem_num = 1;
                sopv.sem_op = 1;
                sopv.sem_flg = SEM_UNDO;
                while(1){//xx2
                        printf("i am customer ,food :%d , space : %d \n",semctl(semid,0,GETVAL),semctl(semid,1,GETVAL));
                        ret =   semop(semid,&sopp,1);
                        ERROR_CHECK(ret,-1,"semop");
                        printf("eatting..\n");
                        ret =   semop(semid,&sopv,1);
                        ERROR_CHECK(ret,-1,"semop");
                        printf("i am customer ,food :%d , space : %d \n",semctl(semid,0,GETVAL),semctl(semid,1,GETVAL));
                        sleep(1);//xx4
                }
        }else{
                struct sembuf sopp,sopv;
                sopp.sem_num = 1;
                sopp.sem_op = -1;
                sopp.sem_flg = SEM_UNDO;
                sopv.sem_num= 0;//xx3  not sopp.sem_num
                sopv.sem_op = 1;//xx3 not sopv.op   not sopv.sem_num
                sopv.sem_flg = SEM_UNDO;
                while(1){
                        printf("i am producer,food:%d,spce :%d\n",semctl(semid,0,GETVAL),semctl(semid,1,GETVAL));
                        ret =   semop(semid,&sopp,1);
                        ERROR_CHECK(ret,-1,"semop");
                        printf("i am producing .. \n");
                        ret =   semop(semid,&sopv,1);
                        ERROR_CHECK(ret,-1,"semop");
                        printf("i am producer ,food :%d , space : %d \n",semctl(semid,0,GETVAL),semctl(semid,1,GETVAL));
                        sleep(2);//xx4
                }
                wait(NULL);
        }
        return 0;
}
```

相关文章

  • 生产者-消费者(计数)

    计数信号量相对互斥锁 的优点: 1,不会出现反复无效解锁,信号量就代表实际的产品空间数量,而不是不管三七二十一先...

  • Dubbo起步

    目录 定义接口 生产者生产者依赖生产者实现 消费者消费者依赖消费者实现 初步印象 定义接口 生产者 生产者依赖 生...

  • 生产者消费者(一)

    生产者消费者模型: 生产者------> 缓存<-------- 消费者

  • 生产者和消费者问题

    生产者和消费者问题 问题简述 组成 系统中有一组生产者和消费者进程 生产者生产者将产品放入缓冲区 消费者消费者进程...

  • 9. python多进程之Queue实现生产者消费者模型

    一、概述 什么是生产者消费者模式生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题。生产者和消费者彼此...

  • 生产者消费者

    什么是生产者和消费者 生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题。 生产者和消费者彼此之间不直...

  • java生产者消费者实现

    什么是生产者消费者模式 生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题。生产者和消费者彼此之间不直...

  • 生产者消费者模式-java原生、Disruptor实现方案

    生产者消费者模式介绍 生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题。生产者和消费者彼此之间不直接...

  • Java实现生产者-消费者模型的几种方法

    什么是生产者消费者模式 生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题。生产者和消费者彼此之间不直...

  • 生产者和消费者模型

    生产者和消费者模型 1. 什么是生产者和消费者模型 生产者消费者模型具体来讲,就是在一个系统中,存在生产者和消费者...

网友评论

      本文标题:生产者-消费者(计数)

      本文链接:https://www.haomeiwen.com/subject/dgepzqtx.html