|
#include #include #include void *producter_f(void *arg); void *consumer_f(void *arg); int buffer_has_item = 0; /*設(shè)置緩存數(shù)量*/ pthread_mutex_t mutex; /*設(shè)置互斥*/ int running = 1; int main (void) { pthread_t consumer_t; /*線程參數(shù)*/ pthread_t producter_t; /*不知道這句為什么不給我變藍(lán)色，初始化互斥*/ pthread_mutex_init(&mutex, NULL); /*創(chuàng)建線程*/ pthread_create(&producter_t, NULL, (void *)producter_f, NULL); pthread_create(&consumer_t, NULL, (void *)consumer_f, NULL); usleep(1); running = 0; /*等待線程退出，一個(gè)線程不能夠被多個(gè)線程等待*/ pthread_join(consumer_t, NULL); pthread_join(producter_t, NULL); /*銷毀互斥*/ pthread_mutex_destroy(&mutex); return 0; } void *producter_f(void *arg) { while (running) { pthread_mutex_lock(&mutex); /*加鎖，進(jìn)入互斥區(qū)*/ buffer_has_item++; printf("product ,num:%d\n", buffer_has_item); pthread_mutex_unlock(&mutex); /*解鎖，離開互斥區(qū)*/ } } void *consumer_f(void *arg) { while (running) { pthread_mutex_lock(&mutex); buffer_has_item--; printf("consumer,num:%d\n",buffer_has_item); pthread_mutex_unlock(&mutex); } } /* *生產(chǎn)者消費(fèi)者問題的信號(hào)量控制，可以與上述程序進(jìn)行對(duì)比，出處--同上 */ #include #include #include void *producter_f(void *arg); void *consumer_f(void *arg); sem_t sem; int running = 1; int main (void) { pthread_t consumer_t; pthread_t producter_t; sem_init(&sem, 0, 16); /*信號(hào)量初始化*/ pthread_create(&producter_t, NULL, (void*)producter_f, NULL); pthread_create(&consumer_t, NULL, (void *)consumer_f, NULL); sleep(1); running = 0; pthread_join(consumer_t, NULL); pthread_join(producter_t, NULL); sem_destroy(&sem); /*銷毀信號(hào)量*/ return 0; } void *producter_f(void *arg) { int semval = 0; /*信號(hào)量的初始值*/ while (running) { usleep(1); sem_post(&sem); /*信號(hào)量+1*/ sem_getvalue(&sem, &semval);/*得到信號(hào)量的值*/ printf("pro,num:%d\n",semval); } } void *consumer_f(void *arg) { int semval = 0; while (running) { usleep(1); sem_wait(&sem); /*信號(hào)量-1*/ sem_getvalue(&sem, &semval); printf("con num:%d\n",semval); } } /* *條件變量來控制線程的同步，根據(jù)百度百科代碼改編而成，不肯定沒有錯(cuò)誤 */ #include #include #include void decrement_count(void); void increment_count(void); /**/ pthread_mutex_t count_lock; /**/ pthread_cond_t count_nonzero; unsigned count; int main(void) { pthread_t decrement_t; pthread_t increment_t; /*初始化互斥*/ pthread_mutex_init(&count_lock, NULL); pthread_create(&decrement_t, NULL, (void*)&decrement_count, NULL); pthread_create(&increment_t, NULL, (void*)&decrement_count, NULL ); usleep(1); pthread_join(decrement_t, NULL); pthread_join(increment_t, NULL); pthread_mutex_destroy(&count_lock); return 0; } void decrement_count(void) { pthread_mutex_lock(&count_lock); while (count == 0) {/*使線程阻塞在一個(gè)條件變量上線程可以被函數(shù)pthread_cond_signal函數(shù)喚醒*/ pthread_cond_wait(&count_nonzero, &count_lock); } count = count - 1; pthread_mutex_unlock(&count_lock); } void increment_count(void) { pthread_mutex_lock(&count_lock); if (count == 0) {/*它用來釋放被阻塞在條件變量cond上的一個(gè)線程*/ pthread_cond_signal(&count_nonzero); } count = count + 1; pthread_mutex_unlock(&count_lock); } |
