生產者
public class producer implements runnable
@override
public void run()
}private void produce()
// 模擬一秒生產一條訊息
thread.sleep(1000);
cache.add(new random().nextint());
cache.notify();
}catch (exception e) }}}
消費者public class consumer implements runnable
@override
public void run()
}private void consume()
system.out.println("consumer consumed [" + cache.remove(0) + "]");
cache.notify();
}catch (exception e) }}}
執行public class waitnotifytest 先來說明兩個定義：
鎖池：假設執行緒a已經擁有了某個物件（不是類）的鎖，而其他執行緒想要呼叫這個物件的synchronize方法（或者synchronize塊），由於這些方法在進入synchronize方法之前必須先或獲得該物件的鎖的擁有權，但是該物件的鎖目前正被執行緒a擁有，所以這些執行緒就進入了該物件的鎖池
等待池：假設執行緒a呼叫了某個物件的wait方法，那麼執行緒a就會釋放該物件的鎖，並且進入等待池中等待喚醒
好了場景模擬
生產者p1,p2
消費者c1,c1
第一回合
c1獲得了物件鎖，c2,p1,p2進入鎖池，但是cache為0，c1進入等待池
round2
c2獲得了物件鎖,p1,p2待在鎖池中，c1待在等待池中，同理c2進入等待池
round3
p1獲得了物件鎖，p2待在鎖池中，c1,c2待在等待池中，p1生產一條訊息，隨機喚醒c1,隨後又進入鎖池
round4
p1又獲得了物件鎖，p2,c1待在鎖池中，c2待在等待池中，cache為1，p1進入等待池
round5
p2獲得了物件鎖，c1待在鎖池中，c2,p1待在等待池中，cache為1，p2進入等待池
round6
c1獲得了物件鎖，鎖池暫空，c2,p1,p2待在等待池中，c1消費一條資料，隨機喚醒c2，隨後又進入了鎖池
round7
c1又獲得了物件鎖，c2待在鎖池中，p1,p2待在等待池中，cache為0，c1進入等待池
round8
c2獲得了物件鎖，cache為0，進入等待池，造成死鎖
簡潔版—>鎖池用表示,等待池用()表示
[c1,c2,p1,p2]()->
c1;[c2,p1,p2]()->
c2;[p1,p2](c1)->
p1;[p2](c1,c2)->
p1;[p2,c1](c2)->
p2;[c1](p1,c2)->
c1;[c2](p1,p2)->
c2;[c1,p1](p2)->
c1;[p1](p2,c2)->
p1;(p2,c2,c1)->
p2;(c2,c1,p1)->
死鎖
p1,[c1,c2,p2]()
p2,[c1,c2](p1)
c1,[c2](p1,p2)
c2,[p1](c1.p2)
p1,(c1,c2,p2)
p2,(c1,c2,p1)
—>死鎖
生產者消費者模型
1.生產者消費者問題 producer consumer 有限緩衝，多執行緒同步。生產者執行緒和消費者執行緒共享固定大小緩衝區。2.關鍵是保證生產者不會再緩衝區滿時加入資料，消費者不會在緩衝區空時消耗資料。3.解決辦法 讓生產者在緩衝區滿時休眠，等下次消費者消耗緩衝區中的資料的時候，生產者才能被喚醒...
生產者消費者模型
生產者與消費者 3,2,1 三種關係 生產者與消費者 互斥，同步 消費者與消費者 互斥 生產者與生產者 互斥 條件變數 int pthread cond destroy pthread cond t cond int pthread cond init pthread cond t restrict...
生產者消費者模型
當佇列滿時，生產者需要等待佇列有空間才能繼續往裡面放入商品，而在等待的期間內，生產者必須釋放對臨界資源 即佇列 的占用權。因為生產者如果不釋放對臨界資源的占用權，那麼消費者就無法消費佇列中的商品，就不會讓佇列有空間，那麼生產者就會一直無限等待下去。因此，一般情況下，當佇列滿時，會讓生產者交出對臨界資...