快捷導(dǎo)航

Java中Object.wait()和LockSupport.park()的用法

更新時(shí)間：2024年05月16日 10:54:42 作者：杉斯狼

Object.wait()和LockSupport.park()都是用來(lái)使當(dāng)前線程等待的方法,本文主要介紹了Java中Object.wait()和LockSupport.park()的用法,具有一定的參考價(jià)值,感興趣的可以了解一下

Object.wait()

用途：wait() 方法屬于對(duì)象監(jiān)視器（Monitor）的一部分，通常與 synchronized 塊或方法一起使用。當(dāng)線程調(diào)用某個(gè)對(duì)象的 wait() 方法時(shí)，它會(huì)釋放該對(duì)象的鎖，并使自己進(jìn)入等待狀態(tài)，直到其他線程調(diào)用該對(duì)象的 notify() 或 notifyAll() 方法喚醒它，此時(shí)線程會(huì)重新嘗試獲取鎖并繼續(xù)執(zhí)行。
位置限制：只能在同步代碼塊或同步方法中調(diào)用，因?yàn)樾枰全@取到對(duì)象的監(jiān)視器鎖。
喚醒條件：可以被 notify() 喚醒，意味著有一個(gè)或多個(gè)等待線程會(huì)被喚醒，但具體哪個(gè)線程被喚醒是不確定的；也可以被 notifyAll() 喚醒，這時(shí)所有等待該對(duì)象監(jiān)視器的線程都會(huì)進(jìn)入鎖的競(jìng)爭(zhēng)狀態(tài)。

LockSupport.park()

用途：park() 方法屬于 java.util.concurrent.locks.LockSupport 類(lèi)，它提供了一種低級(jí)別的線程阻塞原語(yǔ)。它不需要與特定的鎖關(guān)聯(lián)，可以在任何地方調(diào)用，使得線程阻塞。它通常與 unpark() 方法配對(duì)使用，后者可以喚醒一個(gè)調(diào)用了 park() 的線程。
位置限制：沒(méi)有位置限制，可以在任何地方調(diào)用，不需要先獲取鎖。
喚醒條件：調(diào)用 LockSupport.unpark(Thread thread) 方法可以直接喚醒目標(biāo)線程，更加靈活和精確。它可以喚醒一個(gè)特定的線程，而無(wú)需競(jìng)爭(zhēng)或不確定性。
線程許可：park() 和 unpark() 是基于每個(gè)線程的許可（permit）機(jī)制。初始時(shí)，每個(gè)線程沒(méi)有許可，調(diào)用 unpark() 會(huì)給指定線程添加一個(gè)許可，即使之前已經(jīng)調(diào)用過(guò) unpark() 給該線程添加了許可，再調(diào)用也不會(huì)造成影響（許可不會(huì)累積）。調(diào)用 park() 時(shí)，如果沒(méi)有許可，線程會(huì)阻塞，如果有許可，則消耗許可并繼續(xù)執(zhí)行。

總結(jié)來(lái)說(shuō)，Object.wait() 更適合與同步代碼塊或方法一起使用，與對(duì)象的監(jiān)視器鎖緊密相關(guān)，適用于傳統(tǒng)的線程協(xié)作場(chǎng)景；而 LockSupport.park() 提供了一種更底層、更靈活的線程阻塞和喚醒機(jī)制，適用于更復(fù)雜的并發(fā)控制邏輯。

下面是分別使用 Object.wait() 和 LockSupport.park() 的簡(jiǎn)單示例：

使用 Object.wait() 的例子

public class WaitNotifyExample {
    public static void main(String[] args) {
        final Object monitor = new Object();
        
        Thread waitingThread = new Thread(new Runnable() {
            @Override
            public void run() {
                synchronized (monitor) {
                    System.out.println(Thread.currentThread().getName() + " 開(kāi)始等待");
                    try {
                        monitor.wait(); // 等待被喚醒
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread().getName() + " 被喚醒");
                }
            }
        }, "WaitingThread");
        
        Thread notifierThread = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    Thread.sleep(2000); // 模擬一些工作
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                
                synchronized (monitor) {
                    monitor.notify(); // 喚醒等待的線程
                    System.out.println(Thread.currentThread().getName() + " 發(fā)出了喚醒通知");
                }
            }
        }, "NotifierThread");
        
        waitingThread.start();
        notifierThread.start();
    }
}

使用 LockSupport.park() 的例子

import java.util.concurrent.locks.LockSupport;

public class ParkUnparkExample {
    public static void main(String[] args) {
        Thread waitingThread = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println(Thread.currentThread().getName() + " 開(kāi)始等待");
                LockSupport.park(); // 阻塞當(dāng)前線程
                System.out.println(Thread.currentThread().getName() + " 被喚醒");
            }
        }, "WaitingThread");
        
        Thread unparkerThread = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    Thread.sleep(2000); // 模擬一些工作
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                
                System.out.println(Thread.currentThread().getName() + " 準(zhǔn)備喚醒線程");
                LockSupport.unpark(waitingThread); // 喚醒指定線程
            }
        }, "UnparkerThread");
        
        waitingThread.start();
        unparkerThread.start();
    }
}

在這兩個(gè)例子中，第一個(gè)展示了如何使用 Object.wait() 和 notify() 來(lái)實(shí)現(xiàn)線程間的等待與通知，第二個(gè)例子展示了如何使用 LockSupport.park() 和 unpark() 實(shí)現(xiàn)類(lèi)似的線程控制功能，但更為靈活和獨(dú)立于特定鎖。

到此這篇關(guān)于Java中Object.wait()和LockSupport.park()的用法的文章就介紹到這了,更多相關(guān)Java Object.wait() LockSupport.park()內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: