linux c pv 实现生产者消费者模型
2011-10-17 16:25
375 查看
//信号量---线程间通信 //“生产者消费者” 问题 #include<stdio.h> #include<stdlib.h> #include<unistd.h> #include<semaphore.h> #include<pthread.h> #define msleep(x) usleep(x*1000) #define PRODUCT_SPEED 3 //生产速度 #define CONSUM_SPEED 1 //消费速度 #define INIT_NUM 3 //仓库原有产品数 #define TOTAL_NUM 10 //仓库容量 sem_t p_sem, c_sem, sh_sem; int num=INIT_NUM; void product(void) //生产产品 { sleep(PRODUCT_SPEED); } int add_to_lib() //添加产品到仓库 { num++;//仓库中的产品增加一个 msleep(500); return num; } void consum() //消费 { sleep(CONSUM_SPEED); } int sub_from_lib() //从仓库中取出产品 { num--; //仓库中的产品数量减一 msleep(500); return num; } void *productor(void *arg) //生产者线程 { while(1) { sem_wait(&p_sem);//生产信号量减一 product();// 生产延时 sem_wait(&sh_sem);//这个信号量是用来互斥的 printf("push into! tatol_num=%d\n",add_to_lib()); sem_post(&sh_sem); sem_post(&c_sem); //消费信号量加一 } } void *consumer(void *arg) //消费者线程 { while(1) { sem_wait(&c_sem); //消费者信号量减一 sem_wait(&sh_sem); printf("pop out! tatol_num=%d\n",sub_from_lib()); sem_post(&sh_sem); sem_post(&p_sem);//生产者信号量加一 consum();//消费延时 } } int main() { pthread_t tid1,tid2; sem_init(&p_sem,0,TOTAL_NUM-INIT_NUM); sem_init(&c_sem,0,INIT_NUM); sem_init(&sh_sem,0,1); pthread_create(&tid1,NULL,productor,NULL); pthread_create(&tid2,NULL,consumer,NULL); pthread_join(tid1,NULL); pthread_join(tid2,NULL); return 0; }
相关文章推荐
- Linux相互排斥与同步应用(三):posix线程实现单个生产者和单个消费者模型
- Linux实现生产者消费者模型
- Linux互斥与同步应用(三):posix线程实现单个生产者和单个消费者模型
- Linux--Condition Variable(条件变量)实现生产者-消费者模型 、读写锁
- 小白学linux之生产者与消费者模型实现
- Linux C:利用两个线程实现生产者消费者模型
- 生产者与消费者模型Linux下C语言的实现
- Linux——线程锁实现的生产者、消费者模型
- 【Linux】线程总结:线程同步 -互斥锁,条件变量,信号量实现多生产者多消费者模型
- 生产者消费者模型(Linux系统下的两种实现方法)
- 生产者消费者模型(Linux系统下的两种实现方法)
- 浅谈生产者消费者模型(Linux系统下的两种实现方法)
- wait/notifyAll实现生产者消费者模型仿真
- 高性能并发框架 Disruptor 介绍 实现生产者消费者模型
- 生产者与消费者问题(linux下C实现)
- Linux 用pv操作和共享内存实现生产者与消费者机制
- 生产者消费者模型实现多线程异步交互
- wait,notify,非阻塞队列实现生产者,消费者模型
- 简单的生产者和消费者模型——互斥锁和条件变量实现
- Java多线程15:Queue、BlockingQueue以及利用BlockingQueue实现生产者/消费者模型