《Linux應(yīng)用實(shí)例教程》課件-講義29并發(fā)程序-同步與互斥

S10、并發(fā)程序-同步與互斥S10、并發(fā)程序-同步與互斥S10、并發(fā)程序-同步與互斥1、并發(fā)線程同步與互斥#include<stdio.h>#include<stdlib.h>#include<pthread.h>#include<unistd.h>#include<string.h>intnum=30,count=10;pthread_mutex_tmylock=PTHREAD_MUTEX_INITIALIZER;S10、并發(fā)程序-同步與互斥void*sub1(void*arg){

inti=0,tmp;for(;i<count;i++){ pthread_mutex_lock(&mylock);

tmp=num-1; usleep(13);

num=tmp; pthread_mutex_unlock(&mylock); printf("線程1num減1后值為:%d\n",num);} return((void*)0);}S10、并發(fā)程序-同步與互斥void*sub2(void*arg){inti=0,tmp;for(;i<count;i++){ pthread_mutex_lock(&mylock);

tmp=num-1; usleep(31);

num=tmp; pthread_mutex_unlock(&mylock);

printf("線程2num減1后值為:%d\n",num);}return((void*)0);}S10、并發(fā)程序-同步與互斥intmain(intargc,char**argv){

pthread_ttid1,tid2;interr,i=0,tmp;void*tret;err=pthread_create(&tid1,NULL,sub1,NULL);if(err!=0){ printf("pthread_createerror:%s\n",strerror(err));exit(-1);

}err=pthread_create(&tid2,NULL,sub2,NULL);if(err!=0){ printf("pthread_createerror:%s\n",strerror(err));exit(-1);

}S10、并發(fā)程序-同步與互斥for(;i<count;i++){ pthread_mutex_lock(&mylock);

tmp=num-1; usleep(5);

num=tmp; pthread_mutex_unlock(&mylock);

printf("mainnum減1后值為:%d\n",num);}printf("兩個(gè)線程運(yùn)行結(jié)束\n");

err=pthread_join(tid1,&tret);S10、并發(fā)程序-同步與互斥if(err!=0){ printf("cannotjoinwiththread1:%s\n",strerror(err));exit(-1);}printf("thread1exitcode%d\n",(int)tret);err=pthread_join(tid2,&tret);if(err!=0){ printf("cannotjoinwiththread1:%s\n",strerror(err));exit(-1);}printf("thread2exitcode%d\n",(int)tret);return0;}S10、并發(fā)程序-同步與互斥編譯鏈接：gccthreadmutex.c-othreadmutex–lpthread運(yùn)行：./threadmutex

S10、并發(fā)程序-同步與互斥2、生產(chǎn)者-消費(fèi)者同步與互斥問(wèn)題（1）無(wú)同步互斥操作程序（2）運(yùn)行情況（3）有同步互斥操作程序（4）運(yùn)行情況S10、并發(fā)程序-同步與互斥#include<stdio.h>#include<stdlib.h>#include<sys/types.h>#include<pthread.h>#include<unistd.h>#include<signal.h>#include<semaphore.h>#defineMaxbuf10 //緩沖單元數(shù)目#defineTimesOfOp10 //生產(chǎn)者、消費(fèi)者循環(huán)讀寫(xiě)緩沖區(qū)的次數(shù)#definetrue1#definefalse0#definehistorynum100 //生產(chǎn)者、消費(fèi)者讀寫(xiě)歷史記錄數(shù)目S10、并發(fā)程序-同步與互斥structCirclebuf //循環(huán)緩沖隊(duì)列結(jié)構(gòu){ intread; //讀指針 intwrite; //寫(xiě)指針 intbuf[Maxbuf]; //緩沖區(qū)}circlebuf;sem_tmutex; //互斥信號(hào)量sem_tempty; //空白緩沖區(qū)同步信號(hào)量sem_tfull; //滿緩沖區(qū)同步信號(hào)量charwritehistory[historynum][30];//寫(xiě)歷史charreadhistory[historynum][30];//讀歷史intwritehistorycount=0; //寫(xiě)歷史計(jì)數(shù)器intreadhistorycount=0; //讀歷史計(jì)數(shù)器charhistory[historynum][30]; //緩沖區(qū)操作歷史inthistorycount=0; //緩沖區(qū)操作歷史計(jì)數(shù)器S10、并發(fā)程序-同步與互斥voidwriteCirclebuf(structCirclebuf*circlebuf,int*value)//向緩沖區(qū)中寫(xiě)一個(gè)值{ circlebuf->buf[circlebuf->write]=(*value); sleep(1); circlebuf->write=(circlebuf->write+1)%Maxbuf;}intreadCirclebuf(structCirclebuf*circlebuf){ intvalue=0; value=circlebuf->buf[circlebuf->read]; sleep(1); circlebuf->buf[circlebuf->read]=0; circlebuf->read=(circlebuf->read+1)%Maxbuf; returnvalue;}S10、并發(fā)程序-同步與互斥voidsigend(intsig){ exit(0);}void*productThread(void*i){ int*n=(int*)i; intt=TimesOfOp; intwriteptr;S10、并發(fā)程序-同步與互斥 while(t--)

{ sem_wait(&empty); sem_wait(&mutex); writeCirclebuf(&circlebuf,n); if(circlebuf.write>0)writeptr=circlebuf.write-1; elsewriteptr=Maxbuf-1; sprintf(writehistory[writehistorycount++],"生產(chǎn)者%d:緩沖區(qū)%d=%d",*n,writeptr,*n); sprintf(history[historycount++],"生產(chǎn)者%d:緩沖區(qū)%d=%d\n",*n,writeptr,*n); sem_post(&mutex); sem_post(&full); sleep(1); }}S10、并發(fā)程序-同步與互斥void*consumerThread(void*i){ int*n=(int*)i; intt=TimesOfOp; intvalue=0; intreadptr; while(t--) { sem_wait(&full); sem_wait(&mutex); value=readCirclebuf(&circlebuf); if(circlebuf.read>0)readptr=circlebuf.read-1; elsereadptr=Maxbuf-1;S10、并發(fā)程序-同步與互斥 sprintf(readhistory[readhistorycount++],"消費(fèi)者%d:緩沖區(qū)%d=%d\n",*n,readptr,value); sprintf(history[historycount++],"消費(fèi)者%d:緩沖區(qū)%d=%d\n",*n,readptr,value); sem_post(&mutex); sem_post(&empty); sleep(1); }}intmain(){ inti,max; intConsNum=0,ProdNum=0,ret; sem_init(&mutex,0,1);S10、并發(fā)程序-同步與互斥 sem_init(&empty,0,Maxbuf); sem_init(&full,0,0); signal(SIGINT,sigend); signal(SIGTERM,sigend); circlebuf.read=circlebuf.write=0; for(i=0;i<Maxbuf;i++) circlebuf.buf[i]=0; printf("請(qǐng)輸入生產(chǎn)者線程的數(shù)目:"); scanf("%d",&ProdNum); int*pro=(int*)malloc(ProdNum*sizeof(int)); pthread_t*proid=(pthread_t*)malloc(ProdNum*sizeof(pthread_t)); printf("請(qǐng)輸入消費(fèi)者線程的數(shù)目:"); scanf("%d",&ConsNum); int*con=(int*)malloc(ConsNum*sizeof(int));S10、并發(fā)程序-同步與互斥 pthread_t*conid=(pthread_t*)malloc(ConsNum*sizeof(pthread_t)); for(i=1;i<=ConsNum;i++) { con[i-1]=i; ret=pthread_create(&conid[i],NULL,consumerThread,(void*)&con[i-1]); if(ret!=0) { printf("Createthreaderror"); exit(1); } }S10、并發(fā)程序-同步與互斥 for(i=1;i<=ProdNum;i++) { pro[i-1]=i; ret=pthread_create(&proid[i],NULL,productThread,(void*)&pro[i-1]); if(ret!=0) { printf("Createthreaderror"); exit(1); } }

sleep((ConsNum+ProdNum)*10); if(writehist