|
| 1 | + |
| 2 | +# 1. LockSupport简介 # |
| 3 | +在之前介绍[AQS的底层实现](https://juejin.im/post/5aeb07ab6fb9a07ac36350c8),已经在介绍java中的Lock时,比如[ReentrantLock](https://juejin.im/post/5aeb0a8b518825673a2066f0),[ReentReadWriteLocks](https://juejin.im/post/5aeb0e016fb9a07ab7740d90),已经在介绍线程间等待/通知机制使用的[Condition](https://juejin.im/post/5aeea5e951882506a36c67f0)时都会调用LockSupport.park()方法和LockSupport.unpark()方法。而这个在同步组件的实现中被频繁使用的LockSupport到底是何方神圣,现在就来看看。LockSupport位于java.util.concurrent.locks包下,有兴趣的可以直接去看源码,该类的方法并不是很多。LockSupprot是线程的阻塞原语,用来阻塞线程和唤醒线程。每个使用LockSupport的线程都会与一个许可关联,如果该许可可用,并且可在线程中使用,则调用park()将会立即返回,否则可能阻塞。如果许可尚不可用,则可以调用 unpark 使其可用。但是注意许可**不可重入**,也就是说只能调用一次park()方法,否则会一直阻塞。 |
| 4 | + |
| 5 | +# 2. LockSupport方法介绍 # |
| 6 | +LockSupport中的方法不多,这里将这些方法做一个总结: |
| 7 | + |
| 8 | +> **阻塞线程** |
| 9 | + |
| 10 | +1. void park():阻塞当前线程,如果调用unpark方法或者当前线程被中断,从能从park()方法中返回 |
| 11 | +2. void park(Object blocker):功能同方法1,入参增加一个Object对象,用来记录导致线程阻塞的阻塞对象,方便进行问题排查; |
| 12 | +3. void parkNanos(long nanos):阻塞当前线程,最长不超过nanos纳秒,增加了超时返回的特性; |
| 13 | +4. void parkNanos(Object blocker, long nanos):功能同方法3,入参增加一个Object对象,用来记录导致线程阻塞的阻塞对象,方便进行问题排查; |
| 14 | +5. void parkUntil(long deadline):阻塞当前线程,知道deadline; |
| 15 | +6. void parkUntil(Object blocker, long deadline):功能同方法5,入参增加一个Object对象,用来记录导致线程阻塞的阻塞对象,方便进行问题排查; |
| 16 | + |
| 17 | +> **唤醒线程** |
| 18 | + |
| 19 | +void unpark(Thread thread):唤醒处于阻塞状态的指定线程 |
| 20 | + |
| 21 | +实际上LockSupport阻塞和唤醒线程的功能是依赖于sun.misc.Unsafe,这是一个很底层的类,有兴趣的可以去查阅资料,比如park()方法的功能实现则是靠unsafe.park()方法。另外在阻塞线程这一系列方法中还有一个很有意思的现象就是,每个方法都会新增一个带有Object的阻塞对象的重载方法。那么增加了一个Object对象的入参会有什么不同的地方了?示例代码很简单就不说了,直接看dump线程的信息。 |
| 22 | + |
| 23 | +**调用park()方法dump线程**: |
| 24 | + |
| 25 | + "main" #1 prio=5 os_prio=0 tid=0x02cdcc00 nid=0x2b48 waiting on condition [0x00d6f000] |
| 26 | + java.lang.Thread.State: WAITING (parking) |
| 27 | + at sun.misc.Unsafe.park(Native Method) |
| 28 | + at java.util.concurrent.locks.LockSupport.park(LockSupport.java:304) |
| 29 | + at learn.LockSupportDemo.main(LockSupportDemo.java:7) |
| 30 | + |
| 31 | +**调用park(Object blocker)方法dump线程** |
| 32 | + |
| 33 | + "main" #1 prio=5 os_prio=0 tid=0x0069cc00 nid=0x6c0 waiting on condition [0x00dcf000] |
| 34 | + java.lang.Thread.State: WAITING (parking) |
| 35 | + at sun.misc.Unsafe.park(Native Method) |
| 36 | + - parking to wait for <0x048c2d18> (a java.lang.String) |
| 37 | + at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) |
| 38 | + at learn.LockSupportDemo.main(LockSupportDemo.java:7) |
| 39 | + |
| 40 | + |
| 41 | +通过分别调用这两个方法然后dump线程信息可以看出,带Object的park方法相较于无参的park方法会增加 parking to wait for <0x048c2d18> (a java.lang.String)的信息,这种信息就类似于记录"案发现场",有助于工程人员能够迅速发现问题解决问题。有个有意思的事情是,我们都知道如果使用synchronzed阻塞了线程dump线程时都会有阻塞对象的描述,在java 5推出LockSupport时遗漏了这一点,在java 6时进行了补充。还有一点需要需要的是:**synchronzed致使线程阻塞,线程会进入到BLOCKED状态,而调用LockSupprt方法阻塞线程会致使线程进入到WAITING状态。** |
| 42 | + |
| 43 | +# 3. 一个例子 # |
| 44 | + |
| 45 | +用一个很简单的例子说说这些方法怎么用。 |
| 46 | + |
| 47 | + public class LockSupportDemo { |
| 48 | + public static void main(String[] args) { |
| 49 | + Thread thread = new Thread(() -> { |
| 50 | + LockSupport.park(); |
| 51 | + System.out.println(Thread.currentThread().getName() + "被唤醒"); |
| 52 | + }); |
| 53 | + thread.start(); |
| 54 | + try { |
| 55 | + Thread.sleep(3000); |
| 56 | + } catch (InterruptedException e) { |
| 57 | + e.printStackTrace(); |
| 58 | + } |
| 59 | + LockSupport.unpark(thread); |
| 60 | + } |
| 61 | + } |
| 62 | + |
| 63 | +thread线程调用LockSupport.park()致使thread阻塞,当mian线程睡眠3秒结束后通过LockSupport.unpark(thread)方法唤醒thread线程,thread线程被唤醒执行后续操作。另外,还有一点值得关注的是,**LockSupport.unpark(thread)可以指定线程对象唤醒指定的线程**。 |
0 commit comments