Unpark的使用详解

小蓝 • 2024-11-26 05:02 • 编程

一、概述

Unpark是一个Java中的并发包中的类，它可以允许被park的线程重新启动。如果一个线程调用park方法，它就会被阻塞，等待被唤醒。如果没有其他线程调用unpark方法，那么他将一直被阻塞。但是，如果另一个线程调用了与之相关的线程的unpark方法，那么该线程将解除阻塞，继续执行。

二、常用方法

1. park方法

public static void park(Object blocker)

Park一个线程，使该线程进入等待状态，直到其他线程调用unpark方法唤醒它。blocker是一个Object对象，用于调试和监控的目的，一般为null。如果该线程已经被unpark唤醒，在再次调用park时将立即返回。

2. parkNanos方法

public static void parkNanos(Object blocker, long nanos)

与park方法类似，此方法会使线程进入等待状态。不同之处在于，该方法除了可以被其他线程调用unpark唤醒外，还可以在nanos纳秒内等待唤醒，如果在nanos纳秒内没有被唤醒，将自动唤醒。

3. parkUntil方法

public static void parkUntil(Object blocker, long deadline)

与parkNanos方法类似，等待时间限制为deadline。如果超过了deadline，线程将自动唤醒。

4. unpark方法

public static void unpark(Thread thread)

唤醒一个被park的线程。如果线程没有被park，那么它将保持不变。

三、使用实例

1. park和unpark的简单示例

public class Demo {
    public static void main(String[] args) {
        Thread thread = new Thread(() -> {
            System.out.println(Thread.currentThread().getName() + " begin park");
            LockSupport.park();
            System.out.println(Thread.currentThread().getName() + " end park");
        });
        thread.start();
        
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        LockSupport.unpark(thread);
    }
}

输出：
Thread-0 begin park
Thread-0 end park

这个例子中，我们创建了一个线程，它的执行会调用park方法进行等待。在等待过程中，我们调用了unpark方法使其被唤醒。等待过程中被唤醒后，线程继续执行，输出相应的信息。

2. parkUntil实现定时任务

public class Demo {
    public static void main(String[] args) {
        long endTime = System.currentTimeMillis() + 10000;
        Thread thread = new Thread(() -> {
            while (System.currentTimeMillis() < endTime) {
                System.out.println(Thread.currentThread().getName() + " is running");
            }
            System.out.println(Thread.currentThread().getName() + " is over");
        });
        thread.start();
        
        //等待10s后唤醒线程
        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        LockSupport.unpark(thread);
    }
}

输出：
Thread-0 is running
Thread-0 is running
Thread-0 is running
Thread-0 is running
Thread-0 is running
Thread-0 is over

在这个例子中，我们创建了一个线程，它会一直执行，直到当前时间超过endTime。当时间结束后，我们调用unpark方法唤醒线程，结束执行。

四、总结

Unpark是Java并发包中的一个非常重要的类，它可以控制线程的执行状态，实现精细化的线程的管理操作。如果在开发中需要实现一些特定的业务逻辑，那么我们就可以使用Unpark来进行实现。同时，在Unpark的使用中，我们需要注意它的线程安全性，避免出现线程安全问题。

原创文章，作者：小蓝，如若转载，请注明出处：https://www.506064.com/n/184791.html