前言

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

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

正文

一，生產者-消費者模式也是多線程

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

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

我們先用代碼把程序中的資源，生產者，消費者表示出來。

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

本文題目：Java多線程之線程通信生產者消費者模式及等待喚醒機制代碼詳解-創(chuàng)新互聯(lián)
文章地址：http://www.aaarwkj.com/article32/ihgsc.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供服務器托管、動態(tài)網(wǎng)站、ChatGPT、建站公司、網(wǎng)站維護、響應式網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)