Unsafe中的park和unpark

一、方法如下

public native void unpark(Object var1);

public native void park(boolean var1, long var2);

二、使用说明

park：将当前线程挂起。unpark：精准的唤醒某个线程。

park的参数，表示挂起的到期时间，第一个如果是true，表示绝对时间，则var2为绝对时间值，单位是毫秒。第一个参数如果是false，表示相对时间，则var2为相对时间值，单位是纳秒。

unpark的参数，表示线程。

简单示例：

park(false,0) 表示永不到期，一直挂起，直至被唤醒

long time = System.currentTimeMillis()+3000;
park(true,time + 3000) 表示3秒后自动唤醒

park(false,3000000000L) 表示3秒后自动唤醒

三、测试示例

package com.suncy.article.article5;

import sun.misc.Unsafe;

import java.lang.reflect.Field;

public class ParkTest {
    public static void main(String[] args) throws NoSuchFieldException, IllegalAccessException, InterruptedException {
        Field f = Unsafe.class.getDeclaredField("theUnsafe");
        f.setAccessible(true);
        Unsafe unsafe = (Unsafe) f.get(null);

        //线程1必须等待唤醒
        Thread thread1 = new Thread(() -> {
            System.out.println("线程1:执行任务");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
            }
            System.out.println("线程1:挂起，等待唤醒才能继续执行任务");
            unsafe.park(false, 0);
            System.out.println("线程1:执行完毕");
        });
        thread1.start();

        //线程2必须等待唤醒
        Thread thread2 = new Thread(() -> {
            System.out.println("线程2:执行任务");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
            }
            System.out.println("线程2:挂起，等待唤醒才能继续执行任务");
            unsafe.park(false, 0);
            System.out.println("线程2:执行完毕");
        });
        thread2.start();

        Thread.sleep(5000);
        System.out.println("唤醒线程2");
        unsafe.unpark(thread2);
        Thread.sleep(1000);
        System.out.println("唤醒线程1");
        unsafe.unpark(thread1);

        //线程3自动唤醒
        Thread thread3 = new Thread(() -> {
            System.out.println("线程3:执行任务");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
            }
            System.out.println("线程3:挂起，等待时间到自动唤醒");
            unsafe.park(false, 3000000000L);
            System.out.println("线程3:执行完毕");
        });
        thread3.start();

        //线程4自动唤醒
        Thread thread4 = new Thread(() -> {
            System.out.println("线程4:执行任务");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
            }
            System.out.println("线程4:挂起，等待时间到自动唤醒");
            long time = System.currentTimeMillis() + 3000;
            unsafe.park(true, time);
            System.out.println("线程4:执行完毕");
        });
        thread4.start();
    }
}

测试结果：

四、目的

1、使用Unsafe中的park和unpark和上篇文章说的《Unsafe中的CAS》可以完成一个自己的锁，这应该是并发编程基础的前提条件。

作者：空白小小格
链接：https://www.jianshu.com/p/15f33406543b
来源：简书
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。