多線程de小事情

導航不迷路：

程序、進程以及線程的愛恨情仇

最簡單實現多線程的方法（Thread)

簡單易懂的多線程(通過實現Runnable接口實現多線程)

常用獲取線程基本信息的方法（新手專屬）

多線程，你覺得你安全了？（線程安全問題）

多線程別怕，有鎖就安全；（解決線程安全問題）

鎖用不好，可能把自己鎖住哦！（解決多線程的死鎖問題）

---

文章目錄

• 多線程de小事情
• 前言
• 生產者-消費者模式小科普
• • 一、何為生產者
  • 二、何為消費者
  • 三、緩沖區
  • 設置緩沖區的三大優點：
• 代碼
• 總結
• 隨便說說：

---

前言

在多線程中，我們經常需要多個線程并發與協作，簡稱線程并發協作；
那么我們就要了解一個非常經典的一個線程并發模式：生產者-消費者模式；

---

生產者-消費者模式小科普

一、何為生產者

生產者就是負責生產數據的模塊（該模塊可以是對象、方法、進程或是線程）

二、何為消費者

消費者就是負責處理數據的模塊（該模塊可以是對象、方法、進程或是線程）

三、緩沖區

緩沖區是生產者-消費者模式的重要組成部分（核心）；相當一個“容器”，生產者生產數據后會放入緩沖區，消費者會從緩沖區內取需要處理的數據；

看到這里可能就有同學會問了，生產者直接將生產的數據交給消費者不就好了嗎？
為什么還弄的緩沖區，怪麻煩的！
那我們就要看看，緩沖區的優點了：

設置緩沖區的三大優點：

1.通過緩存可以實現并發協作

生產者只需要將生產的數據放入緩沖區內，不需要考慮消費者的消費狀況；同理消費者只需要從緩沖區內拿需要處理的數據，不需要考慮生產者的生產情況；這樣就實現了生產者與消費者的分離；

2.解耦生產者與消費者

生產者不需要與消費者直接打交道；

3.解決忙閑不均，提高效率

當生產者效率低下的時候，緩沖區仍有數據，不會影響消費者的消費；當消費者消費低下時生產者仍可以將生產的數據放入緩沖區；從而避免了互相等待，提高效率；

---

千篇文章，不如代碼一行；

---

代碼

商品類

package sx2; /*** 商品類，包括商品品牌和名稱屬性；* */ public class Commodity1 {private String brand;private String name;public String getBrand() {return brand;}public void setBrand(String brand) {this.brand = brand;}public String getName() {return name;}public void setName(String name) {this.name = name;} }

倉庫類（緩沖區）

package sx2; /*** 倉庫類，相當于緩沖區；* 包括商品屬性，以及進庫，和出庫的方法；* */ public class Warehouse1 {private Commodity1 commodity1;private boolean has;//判斷倉庫是否有商品public Warehouse1(Commodity1 commodity1) {this.commodity1 = commodity1;}public Warehouse1() {} // 入庫與出庫的方法 判斷倉庫是否有商品，有就出庫，沒有入庫public synchronized void set(String brand,String name) {if(has) {try {wait();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}commodity1.setBrand(brand);try {Thread.sleep(300);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}commodity1.setName(name);System.out.println("入庫："+commodity1.getBrand()+commodity1.getName());notify();has=true;}public synchronized void get() {if(!has) {try {wait();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}System.out.println("出庫："+commodity1.getBrand()+commodity1.getName());notify();has=false;}}

生產類

package sx2; /*** 生產者類 * */ public class Producter1 implements Runnable{private Warehouse1 warehouse1;public Producter1() {// TODO Auto-generated constructor stub}public Producter1 (Warehouse1 warehouse1){this.warehouse1 = warehouse1;}// 生產十次，奇數時生產一種商品，偶數時生產另一種商品@Overridepublic void run() {for(int i=0;i<10;i++) {if(i%2==0) {warehouse1.set("東北","凍梨"+i);}else {warehouse1.set("海南", "小芭蕉"+i);}}}}

消費類

package sx2; /*** 消費類* */ public class Customer1 implements Runnable{private Warehouse1 warehouse1;public Customer1() {}public Customer1(Warehouse1 warehouse1) {this.warehouse1 = warehouse1;} // 消費十次@Overridepublic void run() {for(int i=0;i<10;i++) {warehouse1.get();}} }

測試類

package sx2;public class TestSX1 {public static void main(String[] args) {Commodity1 commodity1 = new Commodity1();Warehouse1 warehouse1 = new Warehouse1(commodity1);Producter1 p = new Producter1(warehouse1);Customer1 c = new Customer1(warehouse1);Thread t = new Thread(p);Thread t1 = new Thread(c);t1.start();t.start();}}

效果圖

---

總結

線程并發協作也叫做線程通訊；一般用于生產者-消費者模式：

1、生產者線程與消費者線程共享同一個資源，并且互相依賴，互為條件；
2、在生產者線程的角度，再沒有生產之前，需要消費者線程進入等待狀態，直到生產完成后，通知消費者線程進行消費；
3、在消費者線程的角度，消費結束后，通知生產者線程繼續生產，以供下一次消費；
4、在生產者-消費者問題中，光靠synchronized是不夠的：
?Synchronized可以阻止并發更新同一個共享資源，實現線程的同步；
?Synchronized不能用來實現不同線程之間的通訊；
5、我們可以通過wait()與notify()方法實現，線程間的通訊；（wait()方法有不同的重載方法，還有notifyAll()用于喚醒所有處于等待中的線程）；
6、5中提到的方法，必須要在放在同步代碼塊或是同步方法中否則會報異常；
（他們都是java.lang.Object類的方法）

---

隨便說說：

終于寫完了，多線程之前學習的時候沒怎么學好；
這一次返回來做這一系列的文章，有感覺學到很多以前沒注意的點；
最近在學Spring框架，卡在利用IOC容器管理Bean對象那了，總是報
java.lang.NoClassDefFoundError: org/springframework/context/ApplicationContext這樣的異常；
試了好多方法，也找了好久就是不行；
也好這兩天靜靜，復習一下學過的知識；
學了三個多月的編程了，還是有種云里霧里的感覺；
都說學好框架，工作就穩了，我這剛開始學框架就卡住動不了，也是有點醉了；也不知道以后能找到什么樣的工作；有點期待，又有點緊張；
今天是新年的第二天了，現在許新年愿望應該不晚吧！
希望在新的一年了，自己能提高效率，找到工作，日語能力再次提升；以及祝自己身體健康，平平安安；
最后，也祝愿看到這篇文章的你，一切都往好的方面發展，平平安安，身體健康；
就說到這吧！

感謝您的觀看！

總結

以上是生活随笔為你收集整理的多线程终极模式：生产者-消费者模式的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。