synchronized

synchronized (臨界資源) {// 訪問(wèn)臨界資源的代碼 }

上述代碼的作用是給臨界資源“加鎖”，其他線程訪問(wèn)臨界資源會(huì)被阻塞，目的是保證同一時(shí)間只有一個(gè)線程訪問(wèn)臨界區(qū)。

wait

臨界資源.wait();

某個(gè)線程調(diào)用了臨界資源的wait方法后，該線程被阻塞，直到被其他線程喚醒才能繼續(xù)執(zhí)行。

notify

臨界資源.notify();

某個(gè)線程執(zhí)行該方法后，隨機(jī)喚醒一個(gè)試圖訪問(wèn)臨界區(qū)但處于阻塞狀態(tài)的線程。

完整代碼 demo.java

import java.util.LinkedList; import java.util.Queue;public class demo {Queue<Integer> 臨界資源 = new LinkedList<>();final int MAX = 10;public static void main(String[] args) {demo d = new demo();生產(chǎn)者 producer = d.new 生產(chǎn)者();消費(fèi)者 consumer = d.new 消費(fèi)者();producer.start();consumer.start();}class 生產(chǎn)者 extends Thread {@Overridepublic void run() {while (true) { // 每隔0.5s生產(chǎn)一個(gè)商品synchronized (臨界資源) { // 臨界資源被占用，其他線程訪問(wèn)臨界資源將被阻塞while (臨界資源.size() == MAX) { // 臨界區(qū)已滿，喚醒消費(fèi)者線程，阻塞生產(chǎn)者線程，此處不用 if 是為了保險(xiǎn)臨界資源.notify(); // 喚醒試圖訪問(wèn)臨界資源的阻塞線程System.out.println("臨界區(qū)已滿");try {臨界資源.wait(); // 阻塞當(dāng)前線程，等待其他線程喚醒} catch (InterruptedException e) {e.printStackTrace();}}臨界資源.add(1); // 生產(chǎn)一個(gè)商品臨界資源.notify(); // 喚醒消費(fèi)者System.out.println("已生產(chǎn)1件商品，當(dāng)前商品數(shù)量：" + 臨界資源.size());try {Thread.sleep(500);} catch (InterruptedException e) {e.printStackTrace();}}}}}class 消費(fèi)者 extends Thread {@Overridepublic void run() {while (true) { // 每隔0.5秒消耗一個(gè)商品synchronized (臨界資源) {while (臨界資源.size() == 0) { // 資源耗盡臨界資源.notify();System.out.println("臨界資源耗盡");try {臨界資源.wait();} catch (InterruptedException e) {e.printStackTrace();}}臨界資源.poll(); // 消耗一個(gè)商品臨界資源.notify(); // 喚醒生產(chǎn)者System.out.println("已消耗1件商品，當(dāng)前商品數(shù)量：" + 臨界資源.size());try {Thread.sleep(500);} catch (InterruptedException e) {e.printStackTrace();}}}}} }

總結(jié)

以上是生活随笔為你收集整理的Java synchronized 实现生产者-消费者模型的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。