JUC并发编程——Park Unpark
创始人
2024-05-30 04:21:45
0

一、Park & Unpark

1.1 基本使用

它们是 LockSupport 类中的方法

// 暂停当前线程
LockSupport.park(); 
// 恢复某个线程的运行
LockSupport.unpark(暂停线程对象)

先 park 再 unpark

import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.locks.LockSupport;
import static cn.itcast.n2.util.Sleeper.sleep;@Slf4j(topic = "c.TestParkUnpark")
public class TestParkUnpark {public static void main(String[] args) {Thread t1 = new Thread(() -> {log.debug("start...");sleep(1);log.debug("park...");LockSupport.park();log.debug("resume...");}, "t1");t1.start();// 主线程2s后调用unpark方法sleep(2);log.debug("unpark...");LockSupport.unpark(t1);}
}

运行结果:(t1此时处于无时限的等待状态…)
在这里插入图片描述
先 unpark再 park
在这里插入图片描述

unpark既可以在park之前调用也可在park之后调用

特点

与 Object 的 wait & notify 相比
● wait,notify 和 notifyAll 必须配合 Object Monitor 一起使用,而 park,unpark 不必

● park & unpark 是以线程为单位来【阻塞】和【唤醒】线程,而 notify 只能随机唤醒一个等待线程,notifyAll 是唤醒所有等待线程,就不那么【精确】

● park & unpark 可以先 unpark,而 wait & notify 不能先 notify

1.2 Park & Unpark原理

每个线程都有自己的一个Parker对象(底层由C++代码实现),由三部分组成_counter, _cond 和_mutex 。打个比喻

● 线程就像一个旅人,Parker就像他随身携带的背包,条件变量就好比背包中的帐篷。_counter就好比背包中的备用干粮(0 为耗尽,1为充足)

● 调用park就是要看需不需要停下来歇息
—— 如果备用干粮耗尽,那么钻进帐篷歇息
—— 如果备用干粮充足,那么不需停留,继续前进

● 调用unpark, 就好比令干粮充足
—— 如果这时线程还在帐篷,就唤醒让他继续前进
—— 如果这时线程还在运行,那么下次他调用park时,仅是消耗掉备用干粮,不需停留继续前进
————因为背包空间有限,多次调用unpark仅会补充一份备用干粮

先park 再 unpark
在这里插入图片描述
● 当前线程调用Unsafe.park()
● 检查_counter,本情况为0,这时获得_mutex互斥锁
● 线程进入_cond条件变量阻塞
● 设置_cond=0

unpark再 park
在这里插入图片描述
● 调用Unsafe.unpark(Thread_0)方法,设置_counter为1
● 当前线程调用Unsafe.park()
● 检查_counter,本情况为1,这时线程无需阻塞,继续运行
● 设置_cond=0

二、线程状态转换

从Java层面线程状态分为六种
在这里插入图片描述
假设有线程 Thread t

情况1:NEW --> RUNNABLE
● 当调用 t.start() 方法时,由 NEW --> RUNNABLE

情况2:RUNNABLE <–> WAITING
t 线程用 synchronized(obj) 获取了对象锁后
● 调用 obj.wait() 方法时,t 线程从 RUNNABLE --> WAITING
● 调用 obj.notify() obj.notifyAll() t.interrupt()
—— 竞争锁成功,t 线程从 WAITING --> RUNNABLE
—— 竞争锁失败,t 线程从 WAITING --> BLOCKED

同时唤醒t1、t2线程,锁上的Owner只有一个,因此t1、t2只有一个线程成为Owner(一个竞争锁成功,一个竞争锁失败)

@Slf4j(topic = "c.TestWaitNotify")
public class TestWaitNotify {final static Object obj = new Object();public static void main(String[] args) {new Thread(() -> {synchronized (obj) {log.debug("执行....");try {// 让线程t1在obj上一直等待下去obj.wait(1000);} catch (InterruptedException e) {e.printStackTrace();}log.debug("其它代码....");}},"t1").start();new Thread(()->{synchronized (obj) {log.debug("执行");// 让线程t2在obj上一直等待下去try {obj.wait();} catch (InterruptedException e) {e.printStackTrace();}}},"t2").start();// 主线程0.5秒后执行唤醒线程sleep(0.5);log.debug("唤醒 obj 上其它线程");// 进入同一个对象中的Monitorsynchronized (obj) {obj.notifyAll();}}
}

情况3:RUNNABLE <–> WAITING

● 当前线程调用 t.join() 方法时,当前线程从 RUNNABLE –> WAITING
—— 注意是当前线程在t 线程对象的监视器上等待
● t 线程运行结束,或调用了当前线程的 interrupt() 时,当前线程从 WAITING –> RUNNABLE

情况4:RUNNABLE <–> WAITING

● 当前线程调用 LockSupport.park() 方法会让当前线程从 RUNNABLE --> WAITING
● 调用 LockSupport.unpark(目标线程) 或调用了线程 的 interrupt() ,会让目标线程从 WAITING --> RUNNABLE

情况5:RUNNABLE <–> TIMED_WAITING
t 线程用 synchronized(obj) 获取了对象锁后
● 调用 obj.wait(long n) 方法时,t 线程从 RUNNABLE --> TIMED_WAITING
● t 线程等待时间超过了 n 毫秒,或调用 obj.notify() , obj.notifyAll() , t.interrupt() 时
—— 竞争锁成功,t 线程从 TIMED_WAITING --> RUNNABLE
—— 竞争锁失败,t 线程从 TIMED_WAITING --> BLOCKED

情况6: RUNNABLE <–> TIMED_WAITING
t 线程用 synchronized(obj) 获取了对象锁后
● 当前线程调用 t.join(long n) 方法时,当前线程从 RUNNABLE --> TIMED_WAITING
—— 注意是当前线程在t 线程对象的监视器上等待
t 线程用 synchronized(obj) 获取了对象锁后
● 当前线程等待时间超过了 n 毫秒,或t 线程运行结束,或调用了当前线程的 interrupt() 时,当前线程从TIMED_WAITING --> RUNNABLE

情况7:RUNNABLE <–> TIMED_WAITING

● 当前线程调用 Thread.sleep(long n) ,当前线程从 RUNNABLE --> TIMED_WAITING
● 当前线程等待时间超过了 n 毫秒,当前线程从 TIMED_WAITING --> RUNNABLE

情况8:RUNNABLE <–> TIMED_WAITING

● 当前线程调用 LockSupport.parkNanos(long nanos) 或 LockSupport.parkUntil(long millis) 时,当前线程从 RUNNABLE --> TIMED_WAITING
● 调用 LockSupport.unpark(目标线程) 或调用了线程 的 interrupt() ,或是等待超时,会让目标线程从TIMED_WAITING–> RUNNABLE

情况9:RUNNABLE <–> BLOCKED

● t 线程用 synchronized(obj) 获取了对象锁时如果竞争失败,从 RUNNABLE --> BLOCKED
● 持 obj 锁线程的同步代码块执行完毕,会唤醒该对象上所有 BLOCKED 的线程重新竞争,如果其中 t 线程竞争成功,从 BLOCKED --> RUNNABLE ,其它失败的线程仍然 BLOCKED

情况10:RUNNABLE <–> TERMINATED

当前线程所有代码运行完毕,进入 TERMINATED

相关内容

热门资讯

找不到安卓子系统,揭秘原因及解... 最近我在使用安卓手机的时候遇到了一个让人头疼的问题——找不到安卓子系统!这可真是让我抓耳挠腮,不知道...
安卓p系统如何使用,功能亮点与... 你升级到安卓P系统了吧?是不是有点小激动,想要立刻探索这个新系统的所有酷炫功能呢?别急,让我带你一步...
多多安卓系统app下载,一站式... 你有没有发现,最近手机上多了一个超级酷炫的系统——多多安卓系统!是不是已经跃跃欲试,想要下载体验一番...
r801 安卓系统,深度解析新... 你有没有听说过R801安卓系统?这可是最近在数码圈里炒得火热的一个话题呢!想象你的手机突然变得像一台...
安卓系统国外能用吗,探讨安卓系... 你有没有想过,当你拿着那部心仪的安卓手机,准备出国旅行或者工作的时候,会不会突然发现,哎呀妈呀,这安...
健康怀仁安卓系统下载,健康相伴 你有没有想过,在这个信息爆炸的时代,拥有一款健康、稳定的操作系统是多么重要的事情呢?今天,就让我带你...
手机系统模拟安卓5.0,系统革... 你有没有想过,如果手机系统可以像安卓5.0那样模拟出来,会是怎样的体验呢?想象你手中的设备瞬间变身成...
关闭安卓电池检测系统,解锁续航... 你有没有发现,手机用久了,电池续航能力好像越来越不给力了?是不是觉得安卓系统的电池检测系统太烦人了?...
安卓系统变ios永久,探索系统... 你知道吗?最近在科技圈里可是掀起了一股热潮呢!那就是安卓系统用户纷纷转向iOS系统的现象。这究竟是怎...
安卓系统虚拟按键失灵,原因排查... 手机里的安卓系统突然间出了点小状况,虚拟按键失灵了!这可真是让人头疼不已。想象你正沉浸在游戏的世界里...
安卓北京交警系统繁忙,揭秘安卓... 最近北京的小伙伴们有没有发现,打开手机上的安卓交警系统,那可真是忙得不亦乐乎啊!不信?那就跟着我一起...
苹果和安卓互用系统,共创未来 你有没有想过,为什么你的苹果手机上的应用,有时候也能在安卓手机上顺畅运行呢?这背后,其实有一个神奇的...
安卓系统强制内置相机,隐私与安... 你知道吗?最近在安卓系统上,有一个让人有点摸不着头脑的小变化引起了大家的关注。那就是安卓系统竟然开始...
安卓系统读书app推荐,安卓系... 你有没有发现,随着智能手机的普及,阅读变得越来越方便了呢?尤其是在安卓系统上,各种各样的读书app层...
安卓系统新出的机型,探索【型号... 最近手机圈可是热闹非凡呢!安卓系统新出的机型层出不穷,简直让人眼花缭乱。今天,就让我带你一起探索这些...
安卓与苹果系统游戏,游戏生态对... 你有没有发现,现在手机游戏越来越流行了?不管是走在路上,还是在公交车上,总能看到大家低头玩着手机,那...
闭源系统和安卓开源系统,揭秘闭... 你有没有想过,为什么你的手机里装了那么多应用,却总感觉少了点什么?没错,就是那股自由自在的“玩”劲儿...
小米安卓系统密码破解,揭秘安全... 小米安卓系统密码破解:一场技术与道德的较量在数字化时代,手机已经成为我们生活中不可或缺的一部分。小米...
ios系统游戏转安卓系统游戏,... 你有没有想过,为什么有些游戏在iOS系统上玩得那么顺畅,一到安卓系统上就卡得跟什么似的?今天,就让我...
安卓90系统怎么下载,体验流畅... 你有没有发现,安卓90系统最近可是火得一塌糊涂呢!不少小伙伴都在问,安卓90系统怎么下载?别急,今天...