實(shí)現(xiàn)生產(chǎn)者消費(fèi)者問(wèn)題課程設(shè)計(jì)(編輯修改稿)
2025-04-21 00:36 本頁(yè)面
【文章內(nèi)容簡(jiǎn)介】 ER。//Producer Functionvoid *producer(const int i){ int j。 time_t t。 srand((unsigned) time(amp。t))。//Initialize the random number seed while(1) { sem_wait(amp。blank_number)。 pthread_mutex_lock(amp。counter_mutex)。 sleep(2)。 queue[p]=p+1。 pthread_mutex_unlock(amp。counter_mutex)。 sem_post(amp。product_number)。 printf(Producer Number %d thread identifier: %u ,i+1,((unsigned int)pthread_self()))。 printf(Produce %d\n,queue[p])。 printf(The current state of the buffe：**********************************\n)。 printf( Number:)。 for(j = 0。j NUM。j ++) { printf(%4d,j+1)。 } printf(\n Value:)。 for(j = 0。j NUM。j ++) { printf(%4d,queue[j])。 } printf(\nPointer:)。 for(j = 0。j NUM。j++) { if(j != p) printf( )。 else printf( +)。 } printf(\n)。 p=(p + 1)%NUM。//pbackward one sleep(rand() % 5)。//Random block 04 seconds } return NULL。}//Production of the thread entry functionvoid *producer_thread_fun( unsigned int *arg){ int realarg= (int)arg。//Force type conversion parameters producer(realarg)。 return NULL。}//Consumer functionvoid *consumer(const int i){ int j。 time_t t。 srand((unsigned) time(amp。t))。 while(1) { sem_wait(amp。product_number)。 pthread_mutex_lock(amp。counter_mutex)。 sleep(2)。 printf(Consumer Number %d thread identifier: %u ,i+1,((unsigned int)pthread_self()))。 printf(Consumed %d\n,queue[c])。 queue[c] = 0。//Fill empty posi
范文總結(jié)相關(guān)推薦
鄂ICP備17016276號(hào)-1