Java多线程——线程阻塞工具类LockSupport

简述

LockSupport 是一个非常方便实用的线程阻塞工具,它可以在线程内任意位置让线程阻塞。

和 Thread.suspend()相比,它弥补了由于 resume()在前发生,导致线程无法继续执行的情况。

和 Object.wait()相比,它不需要先获得某个对象的锁,也不会抛出 InterruptedException 异常。

LockSupport 的静态方法 park()可以阻塞当前线程,类似的还有 parkNanos()、parkUntil()等方法。它们实现了一个限时等待,如下图所示:

实例

 1 import java.util.concurrent.locks.LockSupport;
 2 /**
 3  * Created by zhengbinMac on 2017/3/5.
 4  */
 5 public class SuspendResumeTest {
 6     public static Object object = new Object();
 7     static TestThread t1 = new TestThread("线程1");
 8     static TestThread t2 = new TestThread("线程2");
 9     public static class TestThread extends Thread{
10         public TestThread(String name) {
11             super.setName(name);
12         }
13         @Override
14         public void run() {
15             synchronized (object) {
16                 System.out.println(getName()+" 占用。。");
17 //                Thread.currentThread().suspend();
18                 LockSupport.park();
19                 System.out.println(Thread.currentThread().getName()+" 执行结束!");
20             }
21         }
22     }
23     public static void main(String[] args) throws InterruptedException {
24         t1.start();
25         Thread.sleep(200);
26         t2.start();
27 //        t1.resume();
28         LockSupport.unpark(t1);
29         LockSupport.unpark(t2);
30 //        t2.resume();
31         t1.join();
32         t2.join();
33     }
34 }

代码只是对Java多线程——过期的suspend()挂起、resume()继续执行线程中实例稍作修改,将 suspend()和 resume()改为 park()与 unpark()。

修改后,同样的问题:我们依然无法保证 unpark()方法发生在 park()之后,但是多次执行代码,发现始终都可以正常结束,不会因为两方法的顺序导致线程永久性挂起。

这是因为,其使用类似信号量的机制。

它为每个线程准备了一个许可,如果许可可用,那么 park()方法立即返回,并消费这个许可(将许可变为不可用);如果许可不可用,则阻塞。

而 unpark()方法,则是使一个许可变为可用。

上述特点使得:即使 unpark()操作发生在 park()之前,它也可以使下一次得 park()操作立即返回。这是上述实例代码顺利结束的原因。

同时,park()挂起的线程不会像 suspend()那样线程状态为 RUNNABLE,park()会明确给出 WAITING 状态,并标注由 park()引起,如下图所示:

这个标注,使得分析问题时更加方便,可以使用 park(Object)方法,为当前线程设置一个阻塞对象,这个阻塞对象会出现在线程 Dump 中。

将实例中 18 行改为:

LockSupport.park(this);

jstack 输出为:

参考资料

[1] 实战Java高并发程序设计, 3.1.7 - 线程阻塞工具类:LockSupport

[2] Java并发编程的艺术, 5.5 - LockSupport工具

时间: 2024-08-01 20:46:02

Java多线程——线程阻塞工具类LockSupport的相关文章

挂起(suspend)与线程阻塞工具类LockSupport

挂起(suspend)与线程阻塞工具类LockSupport 一般来说是不推荐使用suspend去挂起线程的,因为suspend在导致线程暂停的同时,并不会去释放任何锁资源. 如果其他任何线程想要访问被它暂用的锁时,都会被牵连,导致无法正常继续运行. 直到对应的线程上进行了resume操作. 并且,如果resume操作意外的在suspend前执行了,那么被挂起的线程可能很难有机会被继续执行,更严重的是:它所占用的锁不会被释放,因此可能会导致整个系统工作不正常,而且,对于被挂起的线程,从它的线程状

线程阻塞工具类:LockSupport(读书笔记)

他可以在线程任意位置让线程阻塞, LockSupport的静态方法park()可以阻塞当前线程,类似的还有parkNanos() ParkUntil()等,他们实现了一个限时等待 public class LockSupportDemo { public static Object u = new Object(); static ChangeObjectThread t1 = new ChangeObjectThread("t1"); static ChangeObjectThrea

JAVA 并发编程-线程同步工具类(十二)

本文主要介绍一些java线程同步工具类,并不进行具体讲解,当有需要时,可以再去结合实例学习. 信号灯(Semaphore) 应用场景举例: 例如公司的打卡系统,如果有一个打卡机,那么一次就只能有一个人打卡,其余的人就被阻塞住,打卡完以后就可由下一个人打卡.如果有3个打卡机,那么一次就允许3个人或者少于三个人打卡,其余的人就得等待打卡机空闲下来才能继续打卡. 结果: 已进入1个线程,还可进入2个 已进入2个线程,还可进入1个 已进入3个线程,还可进入0个 空余出1个 已进入4个线程,还可进入0个

Java线程池工具类

使用线程池的好处: 重用线程,线程的创建和销毁是很耗时的. 控制线程的数量. 线程池工具类: ThreadPool.java package com.zws.thread.pool; import java.util.concurrent.Callable; import java.util.concurrent.Future; /**  *   * @author wensh.zhu  *  */ public interface ThreadPool { void execute(Runna

Java线程阻塞中断和LockSupport的常见问题

上周五和周末,工作忙里偷闲,在看java cocurrent中也顺便再温故了一下Thread.interrupt和java 5之后的LockSupport的实现. 在介绍之前,先抛几个问题. Thread.interrupt()方法和InterruptedException异常的关系?是由interrupt触发产生了InterruptedException异常? Thread.interrupt()会中断线程什么状态的工作? RUNNING or BLOCKING? 一般Thread编程需要关注

java 多线程—— 线程等待与唤醒

java 多线程 目录: Java 多线程——基础知识 Java 多线程 —— synchronized关键字 java 多线程——一个定时调度的例子 java 多线程——quartz 定时调度的例子 java 多线程—— 线程等待与唤醒 概述 第1部分 wait(), notify(), notifyAll()等方法介绍 第2部分 wait()和notify()示例 第3部分 wait(long timeout)和notify() 第4部分 wait() 和 notifyAll() 第5部分 

Java多线程——线程之间的同步

Java多线程——线程之间的同步 摘要:本文主要学习多线程之间是如何同步的,以及如何使用synchronized关键字和volatile关键字. 部分内容来自以下博客: https://www.cnblogs.com/hapjin/p/5492880.html https://www.cnblogs.com/paddix/p/5367116.html https://www.cnblogs.com/paddix/p/5428507.html https://www.cnblogs.com/liu

java多线程 -- 线程池

第四种获取线程的方法:线程池,一个 ExecutorService,它使用可能的几个池线程之一执行每个提交的任务,通常使用 Executors 工厂方法配置. 线程池可以解决两个不同问题:由于减少了每个任务调用的开销,它们通常可以在执行大量异步任务时提供增强的性能,并且还可以提供绑定和管理资源(包括执行任务集时使用的线程)的方法.每个 ThreadPoolExecutor 还维护着一些基本的统计数据,如完成的任务数. 为了便于跨大量上下文使用,此类提供了很多可调整的参数和扩展钩子 (hook).

Java多线程之阻塞I/O如何中断

阻塞的I/O线程在关闭线程时并不会被打断,需要关闭资源才能打断.1.执行socketInput.close();阻塞可中断.2.执行System.in.close();阻塞没有中断. package Thread.Interrupting; import java.io.IOException; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket; import java.util.co