【linux】两个线程实现出库与入库操作

apue.h是自己定义的头文件
里面包含
#include
#include <pthread.h>
#incldue

#include "apue.h"#define BUFFER_SIZE 5
#define PRODUCT_CNT 30using namespace std;struct product_cons
{int buffer[BUFFER_SIZE];pthread_mutex_t lock; //互斥锁int readposition;int writeposition;//读写位置pthread_cond_t notempty;   //条件变量 非空pthread_cond_t notfull; //条件变量 非满
}buffer;void init(struct product_cons *p)
{pthread_mutex_init(&p->lock,NULL);pthread_cond_init(&p->notempty,NULL);pthread_cond_init(&p->notfull,NULL);p->readposition = 0 ;p->writeposition = 0 ;
}void finish(struct product_cons *p)
{pthread_mutex_destroy(&p->lock);pthread_cond_destroy(&p->notempty);pthread_cond_destroy(&p->notfull);p->readposition = 0 ;p->writeposition = 0 ;
}void put(struct product_cons *p,int data)
{pthread_mutex_lock(&p->lock);if(p->writeposition + 1 == p->readposition||p->writeposition - 4 == p->readposition){cout << "producer wait for notfull" << endl;pthread_cond_wait(&p->notfull,&p->lock);}p->buffer[p->writeposition]=data;p->writeposition ++;if(p->writeposition >= BUFFER_SIZE){p->writeposition = 0 ;}pthread_cond_signal(&p->notempty);pthread_mutex_unlock(&p->lock);
}int get(struct product_cons *p)
{int data;pthread_mutex_lock(&p->lock);if(p->readposition == p->writeposition){cout << "consumer wait for notempty" << endl;pthread_cond_wait(&p->notempty,&p->lock);}data = p->buffer[p->readposition];p->readposition++;if(p->readposition >= BUFFER_SIZE){p->readposition = 0;}pthread_cond_signal(&p->notfull);pthread_mutex_unlock(&p->lock);return data;
}void*producer(void*data)
{for(int n = 1 ; n < 20 ; n ++ ){sleep(1);cout << "put the" << " " << n <<" " <<  "product..." << endl;put(&buffer,n);cout << "finished put" << endl;}cout <<"the 20 producers has been producted successfully" << endl;return NULL;
}   void*consumer(void*data)
{int NeedNum = 0;while(1){sleep(2);cout << "get product..."<< endl;int num = get(&buffer);cout <<"succeeded get the "<<" "<< num << "product"<<  endl;if(++NeedNum == PRODUCT_CNT){break;}}cout << "the 20 producers has been get successfully" << endl;return NULL;
}int main()
{pthread_t tha,thb;void*retval;int err ;init(&buffer);pthread_create(&tha,NULL,producer,0);pthread_create(&thb,NULL,consumer,0);pthread_join(tha,&retval);  pthread_join(thb,&retval);finish(&buffer);return 0;
}

【linux】两个线程实现出库与入库操作相关推荐

java入库_Java实现商品的查找、添加、出库、入库操作完整案例
本文实例讲述了Java实现商品的查找.添加.出库.入库操作.分享给大家供大家参考,具体如下: package com.jredu.oopch08; public class Goods1 { priv ...
java版出库入库_Java实现商品的查找、添加、出库、入库操作完整案例
本文实例讲述了Java实现商品的查找.添加.出库.入库操作.分享给大家供大家参考,具体如下: package com.jredu.oopch08; public class Goods1 { priv ...
java 等入库完成_Java实现商品的查找、添加、出库、入库操作完整案例
本文实例讲述了Java实现商品的查找.添加.出库.入库操作.分享给大家供大家参考,具体如下: package com.jredu.oopch08; public class Goods1 { priv ...
进销存ERP系统、销售单、采购单、退货单、库存管理、库存盘点、调拨、借入、借出、出库、入库、归还单、收款单、付款单、资金流水、销售报表、采购报表、库存报表、财务报表、商品库、电商erp、连锁erp
进销存ERP系统.销售单.采购单.退货单.库存管理.库存盘点.调拨.借入.借出.出库.入库.归还单.收款单.付款单.资金流水.销售报表.采购报表.库存报表.财务报表.商品库.电商erp.连锁erp A ...
进销存ERP系统、销售单、采购单、退货单、库存管理、库存盘点、调拨、借入、借出、出库、入库、归还单、收款单、付款单、资金流水、销售报表、采购报表、库存报表、财务报表、商品库、电商erp、连锁erp 1
进销存ERP系统.销售单.采购单.退货单.库存管理.库存盘点.调拨.借入.借出.出库.入库.归还单.收款单.付款单.资金流水.销售报表.采购报表.库存报表.财务报表.商品库.电商erp.连锁erp A ...
MySQL小的出库入库_根据出库、入库表，实现对库存的信息查询
数据库:mysql 要求:多个仓库.多个产品表:1.入库凭证表 t_rkpz 2.入库明细表 t_rkpzmx 3.出库凭证表 t_ckpz 4.出库凭证表 t_ckpzmx 说明:两对主从表 [( ...
WMS系统功能分析-出库、库管
出库申请单:单据可以是通过外部系统推送数据到WMS系统生成,或者由WMS提供填报界面.此单存在的意义有两点:1.出库是有缘由的,有的需要走审批流程,最基本的要求也是要有记录,便于日后查询:虽说仓库在出 ...
进程有一个全局变量 i，还有有两个线程。i++ 在两个线程里边分别执行 100 次，能得到的最大值和最小值分别是多少？
转自https://blog.csdn.net/biubiu741/article/details/77990592 多核CPU最小值为2,最大值200. 假设两个线程的执行步骤如下: 1. 线程A执 ...
申请审核和出库审核逻辑
申请审核和出库审核逻辑在实际的场景中,采购回来如笔记本电脑等的高值商品,申请人申请领用时,需要审核人审核通过后,才能流转到库管处出库确认.因此定义不需审核的材料和需要审核的材料不需审核:采购回来的 ...

【linux】两个线程实现出库与入库操作

【linux】两个线程实现出库与入库操作相关推荐

最新文章

热门文章