java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > Java Object.wait() LockSupport.park()

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

作者:杉斯狼

Object.wait()和LockSupport.park()都是用来使当前线程等待的方法,本文主要介绍了Java中Object.wait()和LockSupport.park()的用法,具有一定的参考价值,感兴趣的可以了解一下

Object.wait() 和 LockSupport.park() 都是用来使当前线程等待的方法,但它们在使用场景和机制上有所不同:

Object.wait()

LockSupport.park()

总结来说,Object.wait() 更适合与同步代码块或方法一起使用,与对象的监视器锁紧密相关,适用于传统的线程协作场景;而 LockSupport.park() 提供了一种更底层、更灵活的线程阻塞和唤醒机制,适用于更复杂的并发控制逻辑。

下面是分别使用 Object.wait() 和 LockSupport.park() 的简单示例:

使用 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() + " 开始等待");
                    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() + " 发出了唤醒通知");
                }
            }
        }, "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() + " 开始等待");
                LockSupport.park(); // 阻塞当前线程
                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() + " 准备唤醒线程");
                LockSupport.unpark(waitingThread); // 唤醒指定线程
            }
        }, "UnparkerThread");
        
        waitingThread.start();
        unparkerThread.start();
    }
}

在这两个例子中,第一个展示了如何使用 Object.wait() 和 notify() 来实现线程间的等待与通知,第二个例子展示了如何使用 LockSupport.park() 和 unpark() 实现类似的线程控制功能,但更为灵活和独立于特定锁。

到此这篇关于Java中Object.wait()和LockSupport.park()的用法的文章就介绍到这了,更多相关Java Object.wait() LockSupport.park()内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:
阅读全文