0%
这是一片思考的空间 -- arthinking
Spring 重构&代码整洁之道 软件设计 JVM 并发编程 数据结构与算法 分布式 存储 网络 微服务 设计模式
Java技术栈 - 涉及Java技术体系

如何优雅的挂起线程

我们知道JDK中的Thread.suspend()和Thread.resume()方法是专门用来处理线程挂起和恢复的,但是这两个方法被废弃掉了。

1、为什么不使用suspend和resume() ?

Java Thread Primitive Deprecation[1]这篇官方文章中我们知道,Thread.suspend方法是很容易发生死锁的:如果suspend的目标线程对一个关键的系统资源持有锁,则在恢复目标线程之前,没有线程可以访问该资源。如果将恢复目标线程的线程在调用resume之前,尝试获取同一个关键系统资源,那么就会导致死锁了,从而冻结了进程。以下是该场景的代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
Object lock = new Object();
Thread t1 = new Thread(() -> {
synchronized (lock) {
Thread.currentThread().suspend();
System.out.println("t1 end...");
}
});
Thread t2 = new Thread(() -> {
synchronized (lock) {
t1.resume();
System.out.println("t2 end...");
}
});

t1.start();
Thread.sleep(1000);
t2.start(); // 争抢被锁定的lock而导致死锁,t1也无法醒来

那么什么更好的解决办法呢?下面我们就来介绍下。

2、Object.wait()和Object.notify()

其实这两个方法的实现原理跟ReentrantLock的Condition类似,Object中的方法是在JVM中实现的。

在不同的操作系统上,不同语言的程序,即使没有执行notify或者interrupt或者超时的情况下,条件锁都有可能会产生虚假唤醒的线下。为了避免虚假唤醒之后线程错误的执行,一般都建议吧wait放到循环里面,使用方法:

1
2
3
4
5
synchronized (obj) {
while (<condition does not hold>)
obj.wait(timeout);
... // Perform action appropriate to condition
}

必须先获取synchronized对象锁之后,才可以执行wait()方法。在执行完wait方法之后,对象锁也随着会一起释放掉。

上面的代码我们使用Object的wait和notify方法,将不会产生死锁:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
Object lock = new Object();
Thread t1 = new Thread(() -> {
synchronized (lock) {
try {
lock.wait(); // 线程挂起,进入等待队列,随着对象锁也会自动释放
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("t1 end...");
}

});
Thread t2 = new Thread(() -> {
synchronized (lock) {
lock.notify();
System.out.println("t2 end...");
}
});

t1.start();
Thread.sleep(1000);
t2.start();

注意:notify和wait必须有序进行调用,需要先执行wait,在执行notify。

3、Unsafe.park和Unsafe.unpark

这两个方法与Object.wait()和Object.notify()方法类似,都是用来进行实现线程阻塞和唤醒的。

这两个方法与使用它的每个线程关联一个许可(permit: 0表示无许可,1 表示有许可),如果有许可,将立刻返回对park()的调用,并且在此过程化消耗掉它。否则,park()会导致线程进入阻塞;调用 unpark() 可使许可证可用,如果尚不可用。不过与信号量不同的是,许可证不会累加,最多只有一个。

  • park(Object blocker):实现线程的阻塞。除非有许可,否则出于线程调度目的将阻塞线程;如果有许可,则将许可消耗,然后线程往下继续执行;
  • unpark(Thread thread):实现解除线程的阻塞。如果线程在park方法上被阻塞,则调用该方法将取消阻塞。否则,许可变为1,保证下一次调用park方法不会阻塞。

也就是说,unpark可以先于park执行,先持有许可,保证下一次调用park不会阻塞。

References


  1. Java Thread Primitive Deprecation ↩︎

欢迎关注我的其它发布渠道

订阅IT宅
内功修炼
Java技术栈
Java架构杂谈是IT宅精品文章公众号,欢迎订阅:
📄 网络基础知识:两万字长文50+张趣图带你领悟网络编程的内功心法 📄 HTTP发展史:三万长文50+趣图带你领悟web编程的内功心法 📄 HTTP/1.1:可扩展,可靠性,请求应答,无状态,明文传输 📄 HTTP/1.1报文详解:Method,URI,URL,消息头,消息体,状态行 📄 HTTP常用请求头大揭秘 📄 HTTPS:网络安全攻坚战 📄 HTTP/2:网络安全传输的快车道 📄 HTTP/3:让传输效率再一次起飞 📄 高性能网络编程:图解Socket核心内幕以及五大IO模型 📄 高性能网络编程:三分钟短文快速了解信号驱动式IO 📄 高性能网络编程:彻底弄懂IO复用 - IO处理杀手锏,带您深入了解select,poll,epoll 📄 高性能网络编程:异步IO:新时代的IO处理利器 📄 高性能网络编程:网络编程范式 - 高性能服务器就这么回事 📄 高性能网络编程:性能追击 - 万字长文30+图揭秘8大主流服务器程序线程模型
📄 Java内存模型:如果有人给你撕逼Java内存模型,就把这些问题甩给他 📄 一文带你彻底理解同步和锁的本质(干货) 📄 AQS与并发包中锁的通用实现 📄 ReentrantLock介绍与使用 📄 ReentrantReadWriteLock介绍与使用 📄 ReentrantLock的Condition原理解析 📄 如何优雅的中断线程 📄 如何优雅的挂起线程 📄 图解几个好玩的并发辅助工具类 📄 图解BlockingQueue阻塞队列
📄 消息队列那么多,为什么建议深入了解下RabbitMQ? 📄 高并发异步解耦利器:RocketMQ究竟强在哪里? 📄 Kafka必知必会18问:30+图带您看透Kafka
📄 洞悉MySQL底层架构:游走在缓冲与磁盘之间 📄 SQL运行内幕:从执行原理看调优的本质 📄 洞悉Redis技术内幕:缓存,数据结构,并发,集群与算法