生產者消費者改進模型之二（使用訊號量 互斥量實現）

使用訊號量來實現資源的計數，使得生產者和消費者之間的活動能夠有序進行。詳見**注釋

code:

/*

#include 訊號的型別 sem_t
int sem_init(sem_t *sem, int pshared, unsigned int value);
-初始化訊號量
- 引數：
-sem ：就是訊號量
-value ：用來記錄訊號量中的值
int sem_destroy(sem_t *sem); 
- 釋放資源
int sem_wait(sem_t *sem);
- 對訊號量加鎖，對訊號量的值減1，為零的話就阻塞
int sem_trywait(sem_t *sem); 
int sem_timewait(sem_t *sem, const struct timespec *abs_timeout);
int sem_post(sem_t *sem);
- 解鎖， 呼叫一次就加1，會喚醒阻塞的
int sem_getvalue(sem_t *sem, int *sval);
sem_t psem;
sem_t csem;
init(psem, 0, 8);
init(csem, 0, 0);
producer()      
customer()
*/#include
#include
#include
#include
#include
//建立乙個互斥量
pthread_mutex_t mutex;
//建立兩個訊號量
sem_t psem, csem;
struct node
;//頭結點
struct node* head =
null
;void
*producer
(void
* arg)
return
null;}
void
*customer
(void
* arg)
return
null;}
intmain()
for(
int i =
0; i <5;
++i)
while(1
)pthread_mutex_destroy
(&mutex)
;//這個地方不能立馬銷毀
pthread_exit
(null);
//退出子執行緒
return0;
}

生產者與消費者模型改進

from queue import queue import time,random,threading def xiaofei name,q while true s q.get print s消費了 s name,s time.sleep random.random q.task done 取完...

生產者消費者模型

1.生產者消費者問題 producer consumer 有限緩衝，多執行緒同步。生產者執行緒和消費者執行緒共享固定大小緩衝區。2.關鍵是保證生產者不會再緩衝區滿時加入資料，消費者不會在緩衝區空時消耗資料。3.解決辦法 讓生產者在緩衝區滿時休眠，等下次消費者消耗緩衝區中的資料的時候，生產者才能被喚醒...

生產者消費者模型

生產者與消費者 3,2,1 三種關係 生產者與消費者 互斥，同步 消費者與消費者 互斥 生產者與生產者 互斥 條件變數 int pthread cond destroy pthread cond t cond int pthread cond init pthread cond t restrict...