Java鎖等待喚醒機制

在 Java 并發編程中,鎖的等待和喚醒機制至關重要,通常使用 wait()notify()notifyAll() 來實現線程間的協調。本文將詳細介紹這些方法的用法,并通過示例代碼加以說明。

1. wait()notify()notifyAll()

在 Java 中,Object 類提供了 wait()notify()notifyAll() 方法,它們用于線程間的通信。

  • wait():使當前線程進入等待狀態,并釋放鎖。
  • notify():喚醒單個等待線程。
  • notifyAll():喚醒所有等待線程。

注意,這些方法必須在同步代碼塊(synchronized)中調用,否則會拋出 IllegalMonitorStateException

2. 示例代碼

下面的示例展示了 wait()notify() 的使用。

class SharedResource {private boolean available = false;public synchronized void produce() {while (available) {try {wait();} catch (InterruptedException e) {Thread.currentThread().interrupt();}}System.out.println("Producing an item");available = true;notify();}public synchronized void consume() {while (!available) {try {wait();} catch (InterruptedException e) {Thread.currentThread().interrupt();}}System.out.println("Consuming an item");available = false;notify();}
}public class WaitNotifyExample {public static void main(String[] args) {SharedResource resource = new SharedResource();Thread producer = new Thread(resource::produce);Thread consumer = new Thread(resource::consume);producer.start();consumer.start();}
}

3. wait()notify() 的工作原理

  1. 生產者線程 produce()availabletrue 時調用 wait() 進入等待狀態,釋放鎖。
  2. 消費者線程 consume()availablefalse 時調用 wait() 進入等待狀態,釋放鎖。
  3. produce() 生產后調用 notify() 喚醒 consume()
  4. consume() 消費后調用 notify() 喚醒 produce()

4. notifyAll() 的使用場景

notify() 僅喚醒一個線程,而 notifyAll() 可用于有多個等待線程的情況,以防止某些線程被永久阻塞。

public synchronized void produce() {while (available) {try {wait();} catch (InterruptedException e) {Thread.currentThread().interrupt();}}System.out.println("Producing an item");available = true;notifyAll();
}

5. LockCondition 方式

除了 synchronized,還可以使用 LockCondition 進行等待和喚醒控制。

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;class SharedResourceWithLock {private boolean available = false;private final Lock lock = new ReentrantLock();private final Condition condition = lock.newCondition();public void produce() {lock.lock();try {while (available) {condition.await();}System.out.println("Producing an item");available = true;condition.signal();} catch (InterruptedException e) {Thread.currentThread().interrupt();} finally {lock.unlock();}}public void consume() {lock.lock();try {while (!available) {condition.await();}System.out.println("Consuming an item");available = false;condition.signal();} catch (InterruptedException e) {Thread.currentThread().interrupt();} finally {lock.unlock();}}
}

6. 總結

  • wait()notify() 需要在 synchronized 塊中使用。
  • notifyAll() 可防止線程被永久阻塞。
  • LockCondition 提供更靈活的等待和喚醒機制。

合理使用這些機制可以提升 Java 多線程程序的性能和可靠性。

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/bicheng/74202.shtml
繁體地址,請注明出處:http://hk.pswp.cn/bicheng/74202.shtml
英文地址,請注明出處:http://en.pswp.cn/bicheng/74202.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

? UNIX網絡編程筆記:TCP客戶/服務器程序示例

服務器實例 有個著名的項目&#xff0c;tiny web&#xff0c;本項目將其改到windows下&#xff0c;并使用RAII重構&#xff0c;編寫過程中對于內存泄漏確實很頭疼&#xff0c;還沒寫完&#xff0c;后面會繼續更&#xff1a; #include <iostream> #include <vector&g…

AI Agent開發大全第四課-提示語工程:從簡單命令到AI對話的“魔法”公式

什么是提示語工程&#xff1f;一個讓AI“聽話”的秘密 如果你曾經嘗試過用ChatGPT或者其他大語言模型完成任務&#xff0c;那么你一定遇到過這樣的情況&#xff1a;明明你的問題是清晰的&#xff0c;但答案卻離題萬里&#xff1b;或者你認為自己提供的信息足夠詳盡&#xff0c…

系統架構設計知識體系總結

1.技術選型 1.什么是技術選型&#xff1f; 技術選型是指評估和選擇在項目或系統開發中使用的最合適的技術和工具的過程。這涉及考慮基于其能力、特性、與項目需求的兼容性、可擴展性、性能、維護和其他因素的各種可用選項。技術選型的目標是確定與項目目標相符合、能夠有效解…

基于3DMax與Vray引擎的輕量級室內場景渲染實踐

歡迎踏入3DMAX室內渲染的沉浸式學習之旅!在這個精心設計的實戰教程中,我們將攜手揭開3DMAX與Vray這對黃金搭檔在打造現實室內場景時的核心奧秘。無論您是渴望入門的3D新手,還是追求極致效果的專業設計師,這里都將為您呈現從場景藍圖構建到光影魔法施加的完整技術圖譜。我們…

邏輯卷,vdo,(阿里加速器)

一、邏輯卷 10 20 30 1.邏輯卷的2個特點 &#xff08;1&#xff09;邏輯卷可以將多個分區或者磁盤整合成一個更大的邏輯磁盤&#xff0c;然后可以從邏輯磁盤上劃分出分區&#xff08;邏輯磁盤的大小等于整合的物理磁盤大小之和。&#xff09; &#xff08;2&#xff09;能…

檢索增強生成(2)本地PDF 本地嵌入模型

from langchain_community.document_loaders import PyPDFLoader from pathlib import Pathdef load_local_pdf(file_path):if not Path(file_path).exists():raise FileNotFoundError(f"文件 {file_path} 不存在&#xff01;")loader PyPDFLoader(file_path)try:do…

安全守護:反光衣檢測技術的革新之路

視覺分析助力船上工人反光衣檢測 在現代工業生產與作業環境中&#xff0c;安全始終是首要考慮的因素。對于水上作業&#xff0c;如船舶維護、海上施工等場景&#xff0c;工人穿戴反光衣是預防事故、提高可見性的重要措施。然而&#xff0c;傳統的人工檢查方式不僅效率低下&…

【Scrapy】Scrapy教程8——處理子鏈接

通過前面幾篇文章,已經了解了如何去爬取網頁內容并存儲到數據庫,但是目前只是存儲了一個頁面的內容,現在想要獲取每篇文章鏈接內的文章內容,我們來看看怎么獲取。 生成新請求 首先我們肯定要先拿到鏈接,所以第一步都獲取文章標題和鏈接肯定少不了,然后再爬取獲取到到子…

Centos6配置yum源

Centos6配置yum源 為Centos6配置CentOS Vault源—防止yum源過期為Centos6配置epel源為Centos6配置ELRepo源---已ELRepo被官方清空Centos6安裝dockerdocker配置國內鏡像加速 為Centos6配置CentOS Vault源—防止yum源過期 參考&#xff1a;https://mirrors.ustc.edu.cn/help/cen…

“智改數轉”新風口,物聯網如何重構制造業競爭力?

一、政策背景 為深化制造業智能化改造、數字化轉型、網絡化聯接&#xff0c;江蘇省制定了《江蘇省深化制造業智能化改造數字化轉型網絡化聯接三年行動計劃&#xff08;2025&#xff0d;2027年&#xff09;》&#xff0c;提出到2027年&#xff0c;全省制造業企業設備更新、工藝…

制作Oracle11g Docker 鏡像

基于Linux系統&#xff0c;宿主主機要設置如下環境變量&#xff0c;oracle為64位版本 dockerfile中需要的數據庫安裝包可從csdn下載內找到 #!/bin/bash # 在宿主機上運行以設置Oracle所需的內核參數 # 這些命令需要root權限cat > /etc/sysctl.d/99-oracle.conf << EO…

從GTC2025首次量子日看英偉達量子AI融合算力網絡前景與趨勢

GTC2025 Quantum Day 最新內容全部匯總: 技術名稱描述合作伙伴/開發者應用場景/目標量子模擬器優化方案NVIDIA與IonQ、D-Wave合作,針對量子模擬器進行性能優化,提升量子計算任務效率。IonQ、D-Wave量子算法開發、復雜系統模擬混合量子-經典計算架構結合量子計算與經典GPU加速…

UE4學習筆記 FPS游戲制作12 添加第二把槍,制作槍的父類,動態生成物體,切換武器

我們添加一個發射器類型的槍 我們目前有了一個Rifle的槍械藍圖&#xff0c;我們在添加Launcher時&#xff0c;需要為他們添加一個父類&#xff0c;將公共方法放到父類里&#xff0c;方法體由子類實現 添加父類 方法1 新建一個Gun的藍圖&#xff0c;Gun繼承Actor&#xff0c;…

【原創首發】開源基于AT32 SIP/VOIP電話

前言 本次為了反饋各位粉絲的關注&#xff0c;特此分享 AT32_VOIP 工程&#xff0c;此功能其實跟我之前發過的《STM32F429的VOIP功能》是一樣的&#xff0c;只是用了AT32F437。 其實那個工程是一個比較Demo中的Demo&#xff0c;很多功能和硬件依賴性太大了。后面項目中發現AT…

通俗易懂搞懂@RequestParam 和 @RequestBody

&#x1f4cc; 博主簡介: &#x1f4bb; 努力學習的 23 級科班生一枚 &#x1f680;&#x1f3e0; 博主主頁 &#xff1a; &#x1f4ce; 灰陽陽&#x1f4da; 往期回顧 &#xff1a;Session和Cookie我不允許你不懂&#x1f4ac; 每日一言&#xff1a; 「流水不爭先&#xff0c…

dubbo版本與分組

Dubbo服務中&#xff0c;接口并不能唯一確定一個服務&#xff0c;只有 接口分組版本號 的三元組才能唯一確定一個服務。 當同一個接口針對不同的業務場景、不同的使用需求或者不同的功能模塊等場景&#xff0c;可使用服務分組來區分不同的實現方式。同時&#xff0c;這些不同實…

RAG現有技術方案

RAG現有技術方案 一、現有技術方案的核心問題 檢索質量不足 挑戰:傳統RAG系統依賴單輪檢索,難以應對智能電網的海量異構數據(如傳感器讀數、控制參數),導致檢索結果相關性低、覆蓋不全。案例:BM25稀疏檢索在處理長文本或專業術語時,易遺漏語義關聯;BGE等稠密檢索模型對…

redis MISCONF Redis is configured to save RDB snapshots報錯解決

直接上解決方案 修改redis配置文件 stop-writes-on-bgsave-error no 重啟redis

個人學習編程(3-22) leetcode刷題

連續子數組&#xff1a;&#xff08;難&#xff09; 示例 1: 輸入: nums [0,1] 輸出: 2 說明: [0, 1] 是具有相同數量 0 和 1 的最長連續子數組。 示例 2: 輸入: nums [0,1,0] 輸出: 2 說明: [0, 1] (或 [1, 0]) 是具有相同數量0和1的最長連續子數組。 需要理解的知識&a…

希爾排序

希爾排序是一種改進的插入排序算法&#xff0c;它通過將原始數據分成多個子序列來改善插入排序的性能&#xff0c;每個子序列的元素間隔為 d&#xff08;增量&#xff09;。隨著算法的進行&#xff0c;d 逐漸減小&#xff0c;最終減為 1&#xff0c;此時整個序列就被排序好了。…