多线程实现生产者消费者.doc

《嵌入式Linux编程》 课程设计 题目： 之间的通信 班 级： 计算机应用xxxx班 学 号： 12号 姓 名： x 指导教师： xx 日 期： 2014.6.23～2014.6.27 目 录 一、课程设计说明 1 二、概要设计 1 三、模块设计 2 四、详细设计 4 五、程序调试 6 六、总结 8 七、参考文献 9 八、附录 10 一、课程设计说明 生产者-消费者（producer-consumer）问题，也称作有界缓冲区（bounded-buffer）问题，两个进程共享一个公共的固定大小的缓冲区。其中一个是生产者，用于将消息放入缓冲区；另外一个是消费者，用于从缓冲区中取出消息。问题出现在当缓冲区已经满了，而此时生产者还想向其中放入一个新的数据项的情形，其解决方法是让生产者此时进行休眠，等待消费者从缓冲区中取走了一个或者多个数据后再去唤醒它。同样地，当缓冲区已经空了，而消费者还想去取消息，此时也可以让消费者进行休眠，等待生产者放入一个或者多个数据时再唤醒它 二、概要设计 由于该数据结构很小，因而可以对此结构互斥访问。同时，对于每组数据，都有一个标志位，表示此组数据是否被占用，生产者和消费者均可以先占用此位置然后完成相应的操作。 当消费者互斥访问此结构时，首先判断是否有数据可以取，如果没有，直接等待，若有数据可取，先更改标志位占用此数据，并将资源数目-1。然后交出互斥，把数据拷贝到自己缓冲区内，清空数据。当生产者访问时，首先判断有没有空位可以生产，如果没有，直接等待，若有数据可以生产，先判断该位是否被占用，如果没被占用，则占用此位置进行生产。生产完成后，将占用位改为未占用，同时将资源数目+1。 三、模块设计 if(fork() == 0 ) { int i = 0; while( i 100) { semop(emptyid , P ,1 ); semop(mutxid , P , 1); array[*(set)%MAXSEM] = i + 1; printf(Producer %d\n, array[(*set)%MAXSEM]); (*set)++; semop(mutxid , V , 1); semop(fullid , V , 1); i++; } //end of while in line 62 sleep(10); printf(Producer is over); exit(0); } 3.2 消费者进程 //消费者A进程 if(fork()==0) { while(1) { semop(fullid , P , 1); semop(mutxid , P , 1); if(*get == 100) break; *sum+= array[(*get)%MAXSEM]; printf(The ComsumerA Get Number %d\n, array[(*get)%MAXSEM] ); (*get)++; if( *get ==100) printf(The sum is %d \n , *sum); semop(mutxid , V , 1); semop(emptyid , V ,1 ); sleep(1); } //end of while(1) in line 82 printf(ConsumerA is over); exit(0); }//end of if in line 81 else { //消费者B进程 if(fork()==0) { while(1) { semop(fullid , P , 1); semop(mutxid , P , 1); if(*get == 100) break; *sum += array[(*get)%MAXSEM]; printf(The ComsumerB Get Number %d\n, array[(*get)%MAXSEM] ); (*get)++; if( *get ==100) printf(The sum is %d \n , *sum);