生產者消費者模型

生產者消費者模型是通過乙個容器來解決生產者和消費者的強耦合問題。

生產者與消費者彼此之間不直接通訊，而是通過阻塞佇列來進行通訊，所以生產者生產完資料之後不會等待消費者處理，直接扔給阻塞佇列

同時消費者直接從阻塞佇列裡取資料，阻塞佇列就相當於乙個緩衝區，平衡生產者與消費者的資料處理能力

先來複習一下可以用到的乙個重要方法

wait()就是使執行緒停止執行，會釋放物件鎖。

i.wait()方法會使當前執行緒呼叫該方法後進行等待，並且將該執行緒置入鎖物件的等待佇列中，直到接到通知或被中斷為止。

ii.wait()方法只能在同步方法或同步**塊中呼叫，如果呼叫wait()時沒有適當的鎖，會丟擲異常。

iii.wait()方法執行後，當前執行緒釋放鎖，其他執行緒可以競爭該鎖。

wait()之後的執行緒繼續執行由兩種方法:

ii.執行緒等待時呼叫interrupt()中斷該執行緒

wait(long time) : 如果到了預計時間還未被喚醒，執行緒將繼續執行。

/使用wait()方法

public class test 
system.out.println("main方法結束");
}}

ii.notify()方法執行後，喚醒執行緒不會立刻釋放物件鎖，要等待喚醒執行緒全部執行完畢後才釋放物件鎖。

//使用notify()方法

class mythread implements runnable
public void waitmethod()
} catch (exception e) }}
public void notifymethod() catch (exception e) }}
@override
public void run() else 
}}public class test 
}

//使用notifyall()方法喚醒執行緒

class mythread implements runnable
public void waitmethod()
} catch (exception e) }}
public void notifymethod() catch (exception e) }}
@override
public void run() else 
}}public class test 
}

i.呼叫sleep()方法，主動放棄占有的cpu，不會釋放物件鎖

ii.呼叫阻塞式io方法(read()、write())，在該方法返回前，執行緒阻塞。

iii.執行緒試圖獲取乙個monitor，但該monitor被其他執行緒所持有導致阻塞。

iv.執行緒等待某個通知,即呼叫wait(),釋放物件鎖

v.呼叫執行緒suspend()，將執行緒掛起，容易導致死鎖，已被廢棄。

生產者消費者需要第三方來解耦，所以我們模擬乙個簡單的商品的生產者與消費者，生產者執行緒生產乙個商品後消費者執行緒開始消費。

首先建立乙個商品類goods，類中有商品數量以及生產和消費方法

//商品類

class goods
//消費方法
public synchronized void get()
@override
public string tostring()
}//消費者以及生產者類
//生產者
class producer implements runnable
@override
public void run() 
}//消費者
class consumer implements runnable
@override
public void run() 
}//測試類
public class test
}

//商品類

class goods
this.goodsname = goodsname;
this.count = count + 1;
thread.sleep(100);
system.out.println(tostring());
//生產商品之後通知消費者執行緒可以進行消費
notify();//喚醒消費者執行緒
}//消費方法
public synchronized void get() throws interruptedexception 
//每次都消費乙個商品
this.count = this.count-1;
thread.sleep(100);
system.out.println(tostring());
//喚醒生產者執行緒
notify();
}@override
public string tostring()
}//消費者以及生產者類
//生產者
class producer implements runnable
@override
public void run()  catch (interruptedexception e) 
}}//消費者
class consumer implements runnable
@override
public void run()  catch (interruptedexception e) 
}}//測試類
public class test
}

//商品類

class goods
this.goodsname = goodsname;
this.count = count + 1;
thread.sleep(100);
system.out.println(thread.currentthread().getname());
system.out.println(tostring());
//生產商品之後通知消費者執行緒可以進行消費
notifyall();
}//消費方法
public synchronized void get() throws interruptedexception 
//每次都消費乙個商品
this.count = this.count-1;
thread.sleep(100);
system.out.println(thread.currentthread().getname());
system.out.println(tostring());
//喚醒生產者執行緒
notifyall();
}@override
public string tostring()
}//消費者以及生產者類
//生產者
class producer implements runnable
@override
public void run()  catch (interruptedexception e) }}
}//消費者
class consumer implements runnable
@override
public void run()  catch (interruptedexception e) }}
}//測試類
public class test
//5個消費者執行緒
for (int i=0; i<5; i++)
//啟動所有執行緒
for (thread thread : threadlist)
}}

請解釋sleep()與wait()的區別：

1、sleep()是thread類中定義的方法，使用該方法後到了一定時間後執行緒自動喚醒，不會釋放物件鎖

2、wait()是object類中定義的方法，使用該方法後必須使用notify()或notifyall()方法將執行緒喚醒，會釋放物件鎖

生產者消費者模型

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

生產者消費者模型

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

生產者消費者模型

當佇列滿時，生產者需要等待佇列有空間才能繼續往裡面放入商品，而在等待的期間內，生產者必須釋放對臨界資源 即佇列 的占用權。因為生產者如果不釋放對臨界資源的占用權，那麼消費者就無法消費佇列中的商品，就不會讓佇列有空間，那麼生產者就會一直無限等待下去。因此，一般情況下，當佇列滿時，會讓生產者交出對臨界資...