前言

創(chuàng)新互聯(lián)"三網(wǎng)合一"的企業(yè)建站思路。企業(yè)可建設(shè)擁有電腦版、微信版、手機(jī)版的企業(yè)網(wǎng)站。實(shí)現(xiàn)跨屏營銷，產(chǎn)品發(fā)布一步更新，電腦網(wǎng)絡(luò)+移動(dòng)網(wǎng)絡(luò)一網(wǎng)打盡，滿足企業(yè)的營銷需求！創(chuàng)新互聯(lián)具備承接各種類型的網(wǎng)站設(shè)計(jì)制作、網(wǎng)站設(shè)計(jì)項(xiàng)目的能力。經(jīng)過十年的努力的開拓，為不同行業(yè)的企事業(yè)單位提供了優(yōu)質(zhì)的服務(wù)，并獲得了客戶的一致好評(píng)。

前面的例子都是多個(gè)線程在做相同的操作，比如4個(gè)線程都對(duì)共享數(shù)據(jù)做tickets–操作。大多情況下，程序中需要不同的線程做不同的事，比如一個(gè)線程對(duì)共享變量做tickets++操作，另一個(gè)線程對(duì)共享變量做tickets–操作，這就是大名鼎鼎的生產(chǎn)者和消費(fèi)者模式。

正文

一，生產(chǎn)者-消費(fèi)者模式也是多線程

生產(chǎn)者和消費(fèi)者模式也是多線程的范例。所以其編程需要遵循多線程的規(guī)矩。

首先，既然是多線程，就必然要使用同步。上回說到，synchronized關(guān)鍵字在修飾函數(shù)的時(shí)候，使用的是“this”鎖，所以在同一個(gè)類中的函數(shù)被synchronized修飾后，使用的是同一把鎖。線程調(diào)用這些函數(shù)時(shí)，不管調(diào)用的是tickets++操作函數(shù)，還是tickets–函數(shù)，都會(huì)先去判斷是否加鎖了，得到鎖之后再去進(jìn)行具體的操作。

我們先用代碼把程序中的資源，生產(chǎn)者，消費(fèi)者表示出來。

package com.jimmy.ThreadCommunication;
class Resource{  // 資源類
  private String productName; // 資源名稱
  private int count = 1;    // 資源編號(hào)
  public void produce(String name){  // 生產(chǎn)資源函數(shù)
    this.productName = name + count;
    count ++;  // 資源編號(hào)遞增，用來模擬資源遞增
    System.out.println(Thread.currentThread().getName()+"...生產(chǎn)者.."+this.productName);
  }
  public void consume() { // 消費(fèi)資源函數(shù)
    System.out.println(Thread.currentThread().getName()+"...消費(fèi)者.."+this.productName);    
  }
}
class Producer implements Runnable{ // 生產(chǎn)者類，用于開啟生產(chǎn)者線程
  private Resource res;
  //生產(chǎn)者初始化就要分配資源
  public Producer(Resource res) {  
    this.res = res;
  }
  @Override
  public void run() {
    for (int i = 0; i < 10; i++) {     
      res.produce("bread");   // 循環(huán)生產(chǎn)10次
    }
  }
}
class Comsumer implements Runnable{  // 消費(fèi)者類，用于開啟消費(fèi)者線程
  private Resource res;
  //同理，消費(fèi)者一初始化也要分配資源
  public Comsumer(Resource res) {
    this.res = res;
  }
  @Override
  public void run() {
    for (int i = 0; i < 10; i++) {     
      res.consume(); // 循環(huán)消費(fèi)10次
    }
  }
}
public class ProducerAndConsumer1 {
  public static void main(String[] args) {
    Resource resource = new Resource(); // 實(shí)例化資源
    Producer producer = new Producer(resource); // 實(shí)例化生產(chǎn)者和消費(fèi)者類，它們?nèi)〉猛粋€(gè)資源
    Comsumer comsumer = new Comsumer(resource);
    Thread threadProducer = new Thread(producer); // 創(chuàng)建1個(gè)生產(chǎn)者線程
    Thread threadComsumer = new Thread(comsumer); // 創(chuàng)建1個(gè)消費(fèi)者線程
    threadProducer.start(); // 分別開啟線程
    threadComsumer.start();
  }
}

文章標(biāo)題：Java多線程之線程通信生產(chǎn)者消費(fèi)者模式及等待喚醒機(jī)制代碼詳解-創(chuàng)新互聯(lián)
標(biāo)題來源：http://weahome.cn/article/ihgsc.html