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

相关内容

热门资讯

安卓系统能跑win吗,探索跨平... 你有没有想过,你的安卓手机里能不能装上Windows系统呢?这听起来是不是有点像科幻电影里的情节?别...
安卓车载系统蓝牙设置,畅享智能... 你有没有发现,现在开车的时候,手机和车载系统之间的互动越来越频繁了呢?这不,今天就来给你详细说说安卓...
奥利奥安卓系统,探索新一代智能... 你有没有想过,一块小小的奥利奥饼干竟然能和强大的安卓系统扯上关系?没错,今天就要来聊聊这个跨界组合,...
微信使用安卓系统,功能解析与操... 你有没有发现,现在用微信的人越来越多了呢?尤其是安卓系统的用户,简直就像潮水一样涌来。今天,就让我带...
体验最新原生安卓系统,极致体验... 你有没有想过,手机系统就像是我们生活的调味品,有时候换一种口味,生活都会变得有趣起来呢?最近,我体验...
安卓系统能玩原神,尽享奇幻冒险... 你有没有想过,在安卓系统上也能畅玩《原神》这样的热门游戏呢?没错,就是那个画面精美、角色丰富、玩法多...
安卓写手机银行系统,基于安卓平... 你有没有想过,手机银行系统在我们日常生活中扮演了多么重要的角色呢?每天刷刷手机,就能轻松管理账户,转...
僵尸之夜恐怖安卓系统,揭秘恐怖... 僵尸之夜,恐怖安卓系统来袭!想象一个寂静的夜晚,你正沉浸在美梦中,突然,一阵诡异的铃声打破了夜的宁静...
谷歌框架和安卓系统,构建智能移... 你有没有想过,为什么你的手机那么聪明,能帮你找到路线,还能帮你拍出美美的照片呢?这都要归功于一个超级...
安卓系统和oppo系统哪个流畅... 你有没有想过,手机系统哪个更流畅呢?安卓系统和OPPO系统,这两个名字听起来就让人心动。今天,咱们就...
安卓怎么用微软系统,利用微软系... 你是不是也和我一样,对安卓手机上的微软系统充满了好奇?想象那熟悉的Windows界面在你的安卓手机上...
安卓系统如何安装nfc,安卓系... 你有没有想过,用手机刷公交卡、支付账单,是不是比掏出钱包来得酷炫多了?这就得归功于NFC技术啦!今天...
ios系统可以转安卓,跨平台应... 你有没有想过,你的iPhone手机里的那些宝贝应用,能不能搬到安卓手机上继续使用呢?没错,今天就要来...
iOSapp移植到安卓系统,i... 你有没有想过,那些在iOS上让你爱不释手的app,是不是也能在安卓系统上大放异彩呢?今天,就让我带你...
现在安卓随便换系统,探索个性化... 你知道吗?现在安卓手机换系统简直就像换衣服一样简单!没错,就是那种随时随地、随心所欲的感觉。今天,就...
安卓系统安装按钮灰色,探究原因... 最近发现了一个让人头疼的小问题,那就是安卓手机的安装按钮突然变成了灰色,这可真是让人摸不着头脑。你知...
安卓7.1.1操作系统,系统特... 你知道吗?最近我在手机上发现了一个超级酷的新玩意儿——安卓7.1.1操作系统!这可不是什么小打小闹的...
安卓os系统怎么设置,并使用`... 你有没有发现,你的安卓手机有时候就像一个不听话的小孩子,有时候设置起来真是让人头疼呢?别急,今天就来...
安卓降低系统版本5.1,探索安... 你知道吗?最近安卓系统又来了一次大动作,竟然把系统版本给降到了5.1!这可真是让人有点摸不着头脑,不...
解放安卓系统被保护,解放安卓系... 你有没有想过,你的安卓手机其实可以更加自由地呼吸呢?是的,你没听错,我说的就是解放安卓系统被保护的束...