前言

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

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

正文

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

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

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

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

package com.jimmy.ThreadCommunication;
class Resource{  // 資源類
  private String productName; // 資源名稱
  private int count = 1;    // 資源編號
  public void produce(String name){  // 生產(chǎn)資源函數(shù)
    this.productName = name + count;
    count ++;  // 資源編號遞增，用來模擬資源遞增
    System.out.println(Thread.currentThread().getName()+"...生產(chǎn)者.."+this.productName);
  }
  public void consume() { // 消費資源函數(shù)
    System.out.println(Thread.currentThread().getName()+"...消費者.."+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{  // 消費者類，用于開啟消費者線程
  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); // 實例化生產(chǎn)者和消費者類，它們?nèi)〉猛粋€資源
    Comsumer comsumer = new Comsumer(resource);
    Thread threadProducer = new Thread(producer); // 創(chuàng)建1個生產(chǎn)者線程
    Thread threadComsumer = new Thread(comsumer); // 創(chuàng)建1個消費者線程
    threadProducer.start(); // 分別開啟線程
    threadComsumer.start();
  }
}

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

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

廣告

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