[经验]

课程设计求助

2069

问答对人有帮助，内容完整，我也想知道答案 0 我们开始做课程设计了，但我不会linux的编程。求助程序啊！！题目是：基于信号量及共享内存的生产者和消费者。要求是：编写两个程序两个程序使用共享内存sharemem作为产品缓冲区，一个程序作为生产者，一次课产生指定数目的产品（若干字符）添加到共享内存sharemem尾部。另一个程序作为消费者，从共享内存sharemem头部开始消费产品（读取若干字符），然后将已消费字符从共享内存中删除，当共享内存中的字符不足时，消费进程阻塞，直到生产者生产出了指定个数的字符时，使用信号量控制生产者进程和消费者进程对共享内存的互斥访问，并编写编译所需的makefile文件。求大神给我写个对应的linux程序。一定要写上注释啊！！我还要把程序看懂去答辩。。跪谢！！ 0 已退回10积分
2015-6-30 13:11:36　　评论淘帖0 邀请回答您可以邀请以下用户，快速回答问题 × 嵌入式-H 该类别下有 22 个回答。邀请回答 906073882 该类别下有 15 个回答。邀请回答逸興遄飛该类别下有 10 个回答。邀请回答杨永胜该类别下有 10 个回答。邀请回答 fangzhan9527269 该类别下有 9 个回答。邀请回答 liang_zhen 该类别下有 5 个回答。邀请回答 ty_shi 该类别下有 5 个回答。邀请回答 jinyi7016 该类别下有 4 个回答，其中被选为最佳答案 1 次。邀请回答 Somnus_H 该类别下有 4 个回答。邀请回答坚持就好该类别下有 3 个回答。邀请回答 leifukes 该类别下有 3 个回答。邀请回答李英杰该类别下有 3 个回答。邀请回答 h1654155962.6206 该类别下有 3 个回答。邀请回答 richthoffen 该类别下有 3 个回答。邀请回答迷乱该类别下有 3 个回答。邀请回答 MagicRain 该类别下有 3 个回答。邀请回答西雅图之恋该类别下有 3 个回答。邀请回答余悦勇该类别下有 3 个回答。邀请回答 jansert 该类别下有 2 个回答。邀请回答吃很多很多柚子该类别下有 2 个回答。邀请回答举报 beyondthegame 相关推荐 • 求助，求labview课程设计程序，重奖 2667 • 求助一篇关于信号波形仿真的课程设计 1868 • 求labview课程设计 3357 • 体温监护仪课程设计 3904 • Labview课程设计 3373 • 课程设计求助 2789 • 谁有protel 的课程设计 1961 • LABVIEW课程设计 3612 • labview的课程设计 2435 • 求助一个模拟电梯单片机课程设计 2076 1个回答

答案对人有帮助，有参考价值 0 可能直接写程序工作量太大了吧。我在网上找了一个程序，大神们能不能就在这个程序上修改一个对应我题目的程序出来啊？？ #include "stdio.h" #include #include #include #define SHM_SIZE (10241024) #define SHM_MODE 0600 #define SEM_MODE 0600 #if defined(__GNU_LIBRARY__) && !defined(_SEM_SEMUN_UNDEFINED) / union semun is defined by including / #else / according to X/OPEN we have to define it ourselves / union semun{ int val; struct semid_ds buf; unsigned short array; }; #endif struct ShM{ int start; int end; } pSM; const int N_CONSUMER = 3;//消费者数量 const int N_BUFFER = 5;//缓冲区容量 int shmId = -1,semSetId=-1; union semun su;//sem union，用于初始化信号量 //semSetId 表示信号量集合的 id //semNum 表示要处理的信号量在信号量集合中的索引 void waitSem(int semSetId,int semNum) { struct sembuf *; .sem_num = semNum; .sem_op = -1;//表示要把信号量减一 .sem_flg = SEM_UNDO;// //第二个参数是 sembuf [] 类型的，表示数组 //第三个参数表示第二个参数代表的数组的大小 if(semop(semSetId,&,1) < 0){ perror("waitSem failed"); exit(1); } } void sigSem(int semSetId,int semNum) { struct sembuf ; .sem_num = semNum; .sem_op = 1; .sem_flg = SEM_UNDO; //第二个参数是 sembuf [] 类型的，表示数组 //第三个参数表示第二个参数代表的数组的大小 if(semop(semSetId,&,1) < 0){ perror("waitSem failed"); exit(1); } } //必须在保证互斥以及缓冲区不满的情况下调用 void produce() { int last = pSM->end; pSM->end = (pSM->end+1) % N_BUFFER; printf("生产 %dn",last); } //必须在保证互斥以及缓冲区不空的情况下调用 void consume() { int last = pSM->start; pSM->start = (pSM->start + 1)%N_BUFFER; printf("消耗 %dn",last); } void init() { //缓冲区分配以及初始化 if((shmId = shmget(IPC_PRIVATE,SHM_SIZE,SHM_MODE)) < 0) { perror("create shared memory failed"); exit(1); } pSM = (struct ShM )shmat(shmId,0,0); pSM->start = 0; pSM->end = 0; //信号量创建 //第一个:同步信号量,表示先后顺序,必须有空间才能生产 //第二个:同步信号量,表示先后顺序,必须有产品才能消费 //第三个:互斥信号量,生产者和每个消费者不能同时进入缓冲区 if((semSetId = semget(IPC_PRIVATE,3,SEM_MODE)) < 0) { perror("create semaphore failed"); exit(1); } //信号量初始化,其中 su 表示 union semun su.val = N_BUFFER;//当前库房还可以接收多少产品 if(semctl(semSetId,0,SETVAL, su) < 0){ perror("semctl failed"); exit(1); } su.val = 0;//当前没有产品 if(semctl(semSetId,1,SETVAL,su) < 0){ perror("semctl failed"); exit(1); } su.val = 1;//为1时可以进入缓冲区 if(semctl(semSetId,2,SETVAL,su) < 0){ perror("semctl failed"); exit(1); } } int main() { int i = 0,child = -1; init(); //创建多个（N_CONSUMER）消费者子进程 for(i = 0; i < N_CONSUMER; i++) { if((child = fork()) < 0)//调用fork失败 { perror("the fork failed"); exit(1); } else if(child == 0)//子进程 { printf("我是第 %d 个消费者子进程，PID = %dn",i,getpid()); while(1) { waitSem(semSetId,1);//必须有产品才能消费 waitSem(semSetId,2);//锁定缓冲区 consume();//获得产品,需要修改缓冲区 sigSem(semSetId,2);//释放缓冲区 sigSem(semSetId,0);//告知生产者,有空间了 sleep(2);//消费频率 } break;//务必有 } } //父进程开始生产 if(child > 0) { while(1) { waitSem(semSetId,0);//获取一个空间用于存放产品 waitSem(semSetId,2);//占有产品缓冲区 produce(); sigSem(semSetId,2);//释放产品缓冲区 sleep(1);//每两秒生产一个 sigSem(semSetId,1);//告知消费者有产品了 } } return 0; }

2015-6-30 18:14:11 评论举报 beyondthegame