Linux下的生产者和消费者场景的代码实现（通过同步）

忘是亡心i 2023-03-03 15:27 15阅读 0赞

#include<iostream>
    #include<pthread.h>
    #include<queue>
    #define   MAX_QUEUE 5
    class BlockQueue{
    	  private:
    		std::queue<int>_queue;
    		int _capacity;
    		pthread_mutex_t  _mutex;
    		pthread_cond_t consumer_cond;
    		pthread_cond_t productor_cond;
    	  public:
    		BlockQueue(int maxq=MAX_QUEUE):_capacity(maxq){
    		  pthread_mutex_init(&_mutex,NULL);
    		  pthread_cond_init(&consumer_cond,NULL);
    		  pthread_cond_init(&productor_cond,NULL);
    		}
    		~BlockQueue(){
    
    		  pthread_mutex_destroy(&_mutex);
    		  pthread_cond_destroy(&consumer_cond);
    		  pthread_cond_destroy(&productor_cond);
    		}
    		bool push(int data){
    		  //加锁
    		  pthread_mutex_lock(&_mutex);
    		  //如果队列满了，就阻塞
    		  while(_queue.size() == _capacity){
    			pthread_cond_wait(&productor_cond,&_mutex);
    		  }
    		  //被唤醒，则表示可以添加数据
    		  _queue.push(data);
    		  //解锁
    		  pthread_mutex_unlock(&_mutex);
    		  //唤醒消费者获取数据进行处理
    		  pthread_cond_signal(&consumer_cond);
    		  return true;
    		}
    		bool pop(int *data){
    		  pthread_mutex_lock(&_mutex);
    		  while(_queue.empty()){
    			pthread_cond_wait(&consumer_cond,&_mutex);
    		  }
    			*data=_queue.front();
    			_queue.pop();
    			pthread_mutex_unlock(&_mutex);
    			pthread_cond_signal(&productor_cond);
    		  return true;
    		}
    };

发表评论取消回复

表情：

评论列表（有 0 条评论，15人围观）

还没有评论，来说两句吧...

相关阅读

相关分享一个生产者-消费者的真实场景

![format_png][] 0.背景现在有一个大数据平台，我们需要通过spark对hive里的数据读取清洗转换(etl)再加其它的业务操作的过程，然后需要把这批数

梦里梦外;/ 2024年03月23日 10:48/ 0 赞/ 95 阅读

相关分享一个生产者-消费者的真实场景

0.背景现在有一个大数据平台，我们需要通过spark对hive里的数据读取清洗转换(etl)再加其它的业务操作的过程，然后需要把这批数据落地到tbase数据库(腾讯的一

梦里梦外;/ 2023年09月25日 23:36/ 0 赞/ 117 阅读

相关 Java 阻塞队列实现生产者和消费者场景

1. 阻塞队列阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加的操作是：在队列为空时，获取元素的线程会等待队列变为非空。

太过爱你忘了你带给我的痛/ 2023年07月08日 09:29/ 0 赞/ 62 阅读

相关 Linux下的生产者和消费者场景的代码实现（通过同步）

include<iostream> include<pthread.h> include<queue> define MAX_QUEUE 5

忘是亡心i/ 2023年03月03日 15:27/ 0 赞/ 16 阅读

相关生产者消费者模型（Java代码实现）

一.死锁？ 1.1什么是死锁？死锁产生的4个必要条件：互斥使用：即当资源被一个线程使用(占有)时，别的线程不能使用不可抢占：资源请求者不能强制从

今天药忘吃喽~/ 2022年10月07日 02:57/ 0 赞/ 241 阅读

相关用代码实现生产者消费者模型

题目：代码实现生产者消费者模型，3个生产者每隔3秒生产1个单位的数据，2个消费者每隔1秒消费一个单位的数据，共享资源是有界的，可以用数组或队列。要求不能出现死锁或者占用CPU不

野性酷女/ 2022年09月10日 08:14/ 0 赞/ 124 阅读

相关生产者消费者模型（Linux系统下的两种实现方法）

生产者消费者问题是同步问题中的一种常见情况，借用一下维基百科的话生产者消费者问题（英语：Producer-consumer problem），也称有限缓冲问题（英语：Bou

偏执的太偏执、/ 2022年08月05日 07:46/ 0 赞/ 131 阅读

相关一个经典的消费者和生产者的实现（linux ）

\include <stdio.h> \include <pthread.h> \define BUFFER\_SIZE 16 // 缓冲区数量 struct pr

心已赠人/ 2022年08月04日 04:24/ 0 赞/ 66 阅读

相关通过wait和notify实现的生产者消费者demo

Java代码 : import java.util.ArrayList; import java.util.List; /\\ \ 通过wait和notify实

迷南。/ 2022年04月15日 07:44/ 0 赞/ 195 阅读

相关 Windows下实现生产者-消费者模型

文章目录要求知识点解析结果分析完整源码要求在 windows 环境下，利用

蔚落/ 2022年02月19日 23:17/ 0 赞/ 271 阅读