1、什么是LockSupport
LockSupport是一个线程阻塞工具,可以在线程任意位置让线程阻塞。线程操作阻塞的方式其实还有Thread.suspend()和Object.wait()。而LockSupport与suspend()相比,弥补了由于resume()方法而导致线程被挂起(类似死锁)的问题,也弥补了wait()需要先获得某个对象锁的问题,也不会抛出InterruptedException异常。
相关API:
2、suspend()和resume()
说到线程阻塞,除了Object.wait()和Object.notify()两种以外,还有Thread.suspend()和Thread.resume()。不过当前这两组API已被弃用,因为他们可能会导致死锁情况发生。
示例代码:
package locksupport;
import java.util.concurrent.TimeUnit;
/**
* @author Shamee loop
* @date 2023/5/19
*/
public class ThreadSuspendTest {
static Object syncObject = new Object();
public static void main(String[] args) throws InterruptedException {
Thread thread1 = new Thread(() -> {
synchronized (syncObject) {
System.out.println(Thread.currentThread().getName() + "执行中,准备挂起");
// 线程挂起
Thread.currentThread().suspend();
}
}, "Thread-1");
Thread thread2 = new Thread(() -> {
synchronized (syncObject) {
System.out.println(Thread.currentThread().getName() + "执行中,准备挂起");
// 线程挂起
Thread.currentThread().suspend();
}
}, "Thread-2");
thread1.start();
TimeUnit.SECONDS.sleep(1);
thread2.start();
// 继续执行
// System.out.println("thread1线程准备执行了resume");
thread1.resume();
// System.out.println("thread1线程执行了resume");
// 继续执行
// System.out.println("thread2线程准备执行了resume");
thread2.resume();
// System.out.println("thread2线程执行了resume");
thread1.join();
thread2.join();
System.out.println("程序运行结束");
}
}
这里模拟了两个线程,运行过程中suspend()挂起,然后使用resume()让线程继续执行。
运行结果:
可以看到程序无法退出,也无法打印“程序运行结束”日志。这就说明程序被永远挂起。原因是suspend()在导致线程暂停的同时,不会释放任何资源。此时其他线程想要访问被占用的锁时,都会导致阻塞。直到线程上进行了resume(),被挂起的线程才能继续。但是如果resume()方法操作以外的在suspend()之前进行了,那么被挂起的资源就尽可能永远被挂起而无法继续。
这里更加注意的时候,这时候被挂起的线程,状态还是Runnable,这些估计也是JDK不推荐的原因吧。
我们将上面几行注释的代码打开,在运行以下:
我们发现thread2的resume()方法在suspend()之前就进行了。因此也解释了为什么thread2没有被继续执行的原因。
3、park()和unpark()
官方文档说了,LockSupport有两个重要的方法,park()和unpark()。而这两个方法很好的弥补了suspend()和resume()的不足。我们上述同等代码,用LockSupport来试下。
package locksupport;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.LockSupport;
/**
* @author Shamee loop
* @date 2023/5/19
*/
public class LockSupportTest {
static Object syncObject = new Object();
public static void main(String[] args) throws InterruptedException {
Thread thread1 = new Thread(() -> {
synchronized (syncObject) {
System.out.println(Thread.currentThread().getName() + "执行中,准备挂起");
LockSupport.park();
}
}, "Thread-1");
Thread thread2 = new Thread(() -> {
synchronized (syncObject) {
System.out.println(Thread.currentThread().getName() + "执行中,准备挂起");
LockSupport.park();
}
}, "Thread-2");
thread1.start();
TimeUnit.SECONDS.sleep(1);
thread2.start();
// 继续执行
// System.out.println("thread1线程准备执行了unpark");
LockSupport.unpark(thread1);
// System.out.println("thread1线程执行了unpark");
// 继续执行
// System.out.println("thread2线程准备执行了unpark");
LockSupport.unpark(thread2);
// System.out.println("thread2线程执行了unpark");
thread1.join();
thread2.join();
System.out.println("程序运行结束");
}
}
运行结果:
可以看到程序正常退出,也打印出“程序运行结束”日志。而代码中只是将原本的suspend()方法替换成LockSupport.park(),将thread1.resume()替换成LockSupport.unpark(thread1)。
这是因为LockSupport使用的是类似信号量的机制。他为每个线程准备了一个许可,如果许可可用,那么park()方法会立刻返回,并且消费这个许可(也就是将许可变成不可用)。如果许可不可用,就会阻塞,而unpark()则是使得一个许可变成可用,但是和信号量不同的时,许可不能累加,不可能拥有超过一个许可。
所以这个特点就使得,即使unpark()方法执行发生在park()之前,他也可以是下一次的park()方法立即返回(因为当前的许可是可用的)。
不仅如此,通常使用park()挂起的状态,不会像suspend()还是Runnabele,他会直接给出waiting状态,同时堆栈也会体现由于park()方法引起,因此相比suspend()来说也更加友好。
我们将上述代码的注释打开,看下运行结果:
可以看到,thread2的unpark()就算运行在了park()之前,程序依然正常运行结束。
4、中断影响
LockSupport方法还支持中断影响。但是他的中断并不是直接抛出InterruptedException,而是默默返回,我们可以从Thread.interrupted方法中获得中断标记。
如代码:
package locksupport;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.LockSupport;
/**
* @author Shamee loop
* @date 2023/5/19
*/
public class LockSupportTest {
static Object syncObject = new Object();
public static void main(String[] args) throws InterruptedException {
Thread thread1 = new Thread(LockSupportTest::doExecuteOn, "Thread-1");
Thread thread2 = new Thread(LockSupportTest::doExecuteOn, "Thread-2");
thread1.start();
TimeUnit.SECONDS.sleep(1);
thread2.start();
thread1.interrupt();
LockSupport.unpark(thread2);
}
private static void doExecuteOn(){
synchronized (syncObject) {
System.out.println(Thread.currentThread().getName() + "执行中,准备挂起");
LockSupport.park();
if(Thread.interrupted()){
System.out.println(Thread.currentThread().getName() + "中断了");
}
System.out.println(Thread.currentThread().getName() + "执行结束");
}
}
}
执行结果:
我们可以看到thread1可以立马响应中断,并且返回,甚至都不用unpark()。返回后,外面的thread2才能占用资源,并最终由unpark(thread2)操作,程序结束。文章来源:https://www.toymoban.com/news/detail-459694.html
5、小结
前面在《【JUC基础】08. 三大工具类》中我们介绍了三大使用的线程辅助类,这里单独介绍线程阻塞控制类。因为我觉得这个工具类和前面的辅助类还是不太一样的。线程的阻塞,唤起是多线程开发中不可或缺的,因此单独拿出来讲。这里使用简单的代码程序说明,希望能有所收获。一天进步一点点~文章来源地址https://www.toymoban.com/news/detail-459694.html
到了这里,关于【JUC基础】09. LockSupport的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!