文章目录
java并发编程原理之---park与unpark
基本使用
情况一，先park再unpark，代码举例与分析
情况二，先unpark再park，代码举例与分析
特点
原理之park & unpark
情况一，先调用park，再调用unpark
先调用park分析
再调用unpark分析
情况二，先调用unpark，再调用park
参考资料
java并发编程原理之—park与unpark
基本使用
它们是LockSupport类中的方法
暂停当前线程
恢复某个线程的运行
LockSupport.park();
LockSupport.unpark(暂停线程对象);
情况一，先park再unpark，代码举例与分析
@Slf4j(topic = "c.TestParkUnpark")
public class TestParkUnpark {
public static void main(String[] args) {
Thread t1 = new Thread(() -> {
log.debug("start...");
sleep(1);//t1睡眠了一秒
log.debug("park...");
LockSupport.park();//t1线程一秒后暂停
log.debug("resume...");
}, "t1");
t1.start();
sleep(2);//主线程睡眠二秒
log.debug("unpark...");
LockSupport.unpark(t1);//二秒后由主线程恢复t1线程的运行
}
}
运行结果
"C:\Program Files\Java\jdk1.8.0_191\bin\java.exe" ...
11:10:38.812 c.TestParkUnpark [t1] - start...
11:10:39.816 c.TestParkUnpark [t1] - park...
11:10:40.812 c.TestParkUnpark [main] - unpark...
11:10:40.812 c.TestParkUnpark [t1] - resume...
Process finished with exit code 0
情况二，先unpark再park，代码举例与分析
这里的情况是，主线程先调用了unpark，2秒后，t1线程才执行了park，这时候，思考t1还会运行吗？
@Slf4j(topic = "c.TestParkUnpark")
public class TestParkUnpark {
public static void main(String[] args) {
Thread t1 = new Thread(() -> {
log.debug("start...");
sleep(2);//t1睡眠了两秒
log.debug("park...");
LockSupport.park();//t1线程两秒后暂停
log.debug("resume...");
}, "t1");
t1.start();
sleep(1);//主线程睡眠一秒
log.debug("unpark...");
LockSupport.unpark(t1);//一秒后由主线程恢复t1线程的运行
}
}
运行结果
"C:\Program Files\Java\jdk1.8.0_191\bin\java.exe" ...
11:18:06.790 c.TestParkUnpark [t1] - start...
11:18:07.789 c.TestParkUnpark [main] - unpark...
11:18:08.793 c.TestParkUnpark [t1] - park...
11:18:08.793 c.TestParkUnpark [t1] - resume...
Process finished with exit code 0
可以看到08秒的时候park了，但是并没有停下来，几乎同时执行了下面的打印语句。
特点
与Object的wait ¬ify相比
wait，notify和notifyAll必须配合Object Monitor一起使用，而unpark不必
park & unpark是以线程为单位来【阻塞】和【唤醒】线程，而notify只能随机唤醒一个等待线程，
notifyAll是唤醒所有等待线程，就不那么【精确】
park & unpark可以先unpark，而wait & notify不能先notify
原理之park & unpark
情况一，先调用park，再调用unpark
先调用park分析
1.当前线程调用Unsafe.park()方法
2.检查_counter,本情况为0，这时，获得_mutex互斥锁
3.线程进入_cond条件变量阻塞
4.设置_counter=0
再调用unpark分析
1.调用Unsafe.unpark(Thread_0)方法，设置_counter为1
2.唤醒_cond条件变量中的Thread_0
3.Thread_0恢复运行
4.设置_counter为0
情况二，先调用unpark，再调用park
1.调用Unsafe.unpark(Thread_0)方法，设置_counter为1
2.当前线程调用Unsafe.park()方法
3.检查_counter，本情况为1，这时线程无需阻塞，继续运行
4.设置_counter为0
参考资料
Java的LockSupport.park()实现分析
Java多线程编程实战指南(设计模式篇)-黄海文
如果觉得《java lock park_java并发编程-LockSupport中park与unpark基本使用与原理简单分析》对你有帮助，请点赞、收藏，并留下你的观点哦！
