多线程生产者和消费者

#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <semaphore.h>
#include <unistd.h>
#include <iostream>using namespace std;const int ConsumerNum = 3;
const int PruducterNum = 2;const int M = 20;//缓存区大小int in = 0;
int out = 0;int buff[M] = {0};sem_t empty_sem;//表示空位的数量
sem_t full_sem;//产品的数量pthread_mutex_t mutex;//线程在读取或产生时，都应该加锁
int i=0;//产品Idvoid *product(void *)
{while (true){//sleep(1);sem_wait(&empty_sem);//空位数减1,已经把这个位置站住了，其他线程只能访问剩余位置pthread_mutex_lock(&mutex);cout<<"producter "<<pthread_self()<<" produce "<<i<<endl;buff[in] = i++;in = (in+1)%M;pthread_mutex_unlock(&mutex);sem_post(&full_sem);//产品数加1}
}void *consumer(void *)
{while(true){//sleep(1);sem_wait(&full_sem);pthread_mutex_lock(&mutex);cout<<"consumer "<<pthread_self()<<" consume "<<buff[out]<<endl;out = (out+1)%M;pthread_mutex_unlock(&mutex);sem_post(&empty_sem);}
}int main(void)
{pthread_t consumers[ConsumerNum];pthread_t producters[PruducterNum];sem_init(&empty_sem,0,M);//设初始值为Msem_init(&full_sem,0,0);//初始值为0pthread_mutex_init(&mutex,NULL);for (int ind=0;ind<ConsumerNum;++ind){pthread_create(&consumers[ind],NULL,consumer,(void *)NULL);}for (int ind=0;ind<PruducterNum;++ind){pthread_create(&producters[ind],NULL,product,(void *)NULL);}for(int ind =0;ind<ConsumerNum;++ind)pthread_join(consumers[ind],NULL);for(int ind = 0;ind <PruducterNum;++ind)pthread_join(producters[ind],NULL);exit(0);
}

多线程生产者和消费者相关推荐

Java多线程-生产者与消费者
Java多线程生产者与消费者,准确说应该是"生产者-消费者-仓储"模型,使用了仓储,使得生产者消费者模型就显得更有说服力. 对于此模型,应该明确一下几点: 1.生产者仅仅在仓储未满 ...
java多线程生产者与消费者问题_Java多线程详解之四:生产者消费者问题
一.问题描述生产者消费者问题(Producer-Consumer problem),也称有限缓冲区问题(Bounded-buffer promblem),是一个多线程同步问题的经典案例.对于一个固定 ...
java多线程生产者与消费者问题_java多线程实现生产者与消费者问题
生产者与消费者多线程实现,首先的问题就是同步,就是关于临界资源的访问我们首先来定义一个临界资源类,这里设为Q class Q { int z=4; } 这个int型的z就是我假设的临界资源的个数然 ...
java多线程生产者与消费者案例_多线程操作实例——生产者与消费者
面对多线程学习生产者与消费者是最基本的实例对于java后端开发的人员必须要掌握,还有考研考试计算机操作系统的同鞋. 下面是三个实例对于生产者与消费者的的例子,层层递进,逐步解决问题. 问题:生产者- ...
Java基础进阶多线程-生产者和消费者模式
1.什么是"生产者和消费者模式"? 生产线程负责生产,消费线程负责消费生产线程和消费线程要达到均衡这是一种特殊的业务需求,在这种特殊的情况下需要使用wait方法和notify方 ...
多线程——生产者与消费者（多）1.5新锁，问题解决
package 多线程;import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; imp ...
c++多线程生产者与消费者问题代码
1.目录结构 2.代码 BufferPool.h #ifndef BUFFERPOOL #define BUFFERPOOL #include<windows.h> #include< ...
C++多线程-生产者与消费者模型
生产者-消费者是很有意思的一种算法.它的存在主要是两个目的,第一就是满足生产者对资源的不断创造:第二就是满足消费者对资源的不断索取.当然,因为空间是有限的,所以资源既不能无限存储,也不能无限索取. 生 ...
爬虫多线程生产者与消费者
#-*-coding:utf-8-*- # -*-coding:utf-8-*- import threading, time, requests, json from queue import Qu ...
Java 多线程-生产者、消费者
一.整体代码 ThreadDemo.java public class ThreadDemo { public static void main(String[] args) { Godown god ...

多线程生产者和消费者

多线程生产者和消费者相关推荐

最新文章

热门文章