原創(chuàng)文章&經(jīng)驗總結&從校招到A廠一路陽光一路滄桑

詳情請戳www.codercc.com

image

1. LockSupport簡介

在之前介紹AQS的底層實現(xiàn)，已經(jīng)在介紹java中的Lock時，比如ReentrantLock,ReentReadWriteLocks,已經(jīng)在介紹線程間等待/通知機制使用的Condition時都會調用LockSupport.park()方法和LockSupport.unpark()方法。而這個在同步組件的實現(xiàn)中被頻繁使用的LockSupport到底是何方神圣，現(xiàn)在就來看看。LockSupport位于java.util.concurrent.locks包下，有興趣的可以直接去看源碼，該類的方法并不是很多。LockSupprot是線程的阻塞原語，用來阻塞線程和喚醒線程。每個使用LockSupport的線程都會與一個許可關聯(lián)，如果該許可可用，并且可在線程中使用，則調用park()將會立即返回，否則可能阻塞。如果許可尚不可用，則可以調用 unpark 使其可用。但是注意許可不可重入，也就是說只能調用一次park()方法，否則會一直阻塞。

2. LockSupport方法介紹

LockSupport中的方法不多，這里將這些方法做一個總結：

阻塞線程

1. void park()：阻塞當前線程，如果調用unpark方法或者當前線程被中斷，從能從park()方法中返回
2. void park(Object blocker)：功能同方法1，入?yún)⒃黾右粋€Object對象，用來記錄導致線程阻塞的阻塞對象，方便進行問題排查；
3. void parkNanos(long nanos)：阻塞當前線程，最長不超過nanos納秒，增加了超時返回的特性；
4. void parkNanos(Object blocker, long nanos)：功能同方法3，入?yún)⒃黾右粋€Object對象，用來記錄導致線程阻塞的阻塞對象，方便進行問題排查；
5. void parkUntil(long deadline)：阻塞當前線程，知道deadline；
6. void parkUntil(Object blocker, long deadline)：功能同方法5，入?yún)⒃黾右粋€Object對象，用來記錄導致線程阻塞的阻塞對象，方便進行問題排查；

喚醒線程

void unpark(Thread thread):喚醒處于阻塞狀態(tài)的指定線程

實際上LockSupport阻塞和喚醒線程的功能是依賴于sun.misc.Unsafe，這是一個很底層的類，有興趣的可以去查閱資料，比如park()方法的功能實現(xiàn)則是靠unsafe.park()方法。另外在阻塞線程這一系列方法中還有一個很有意思的現(xiàn)象就是，每個方法都會新增一個帶有Object的阻塞對象的重載方法。那么增加了一個Object對象的入?yún)惺裁床煌牡胤搅?？示例代碼很簡單就不說了，直接看dump線程的信息。

調用park()方法dump線程：

"main" #1 prio=5 os_prio=0 tid=0x02cdcc00 nid=0x2b48 waiting on condition [0x00d6f000]
   java.lang.Thread.State: WAITING (parking)
        at sun.misc.Unsafe.park(Native Method)
        at java.util.concurrent.locks.LockSupport.park(LockSupport.java:304)
        at learn.LockSupportDemo.main(LockSupportDemo.java:7)

調用park(Object blocker)方法dump線程

"main" #1 prio=5 os_prio=0 tid=0x0069cc00 nid=0x6c0 waiting on condition [0x00dcf000]
   java.lang.Thread.State: WAITING (parking)
        at sun.misc.Unsafe.park(Native Method)
        - parking to wait for  <0x048c2d18> (a java.lang.String)
        at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
        at learn.LockSupportDemo.main(LockSupportDemo.java:7)

通過分別調用這兩個方法然后dump線程信息可以看出，帶Object的park方法相較于無參的park方法會增加 parking to wait for <0x048c2d18> (a java.lang.String）的信息，這種信息就類似于記錄“案發(fā)現(xiàn)場”，有助于工程人員能夠迅速發(fā)現(xiàn)問題解決問題。有個有意思的事情是，我們都知道如果使用synchronzed阻塞了線程dump線程時都會有阻塞對象的描述，在java 5推出LockSupport時遺漏了這一點，在java 6時進行了補充。還有一點需要需要的是：synchronzed致使線程阻塞，線程會進入到BLOCKED狀態(tài)，而調用LockSupprt方法阻塞線程會致使線程進入到WAITING狀態(tài)。

3. 一個例子

用一個很簡單的例子說說這些方法怎么用。

public class LockSupportDemo {
    public static void main(String[] args) {
        Thread thread = new Thread(() -> {
            LockSupport.park();
            System.out.println(Thread.currentThread().getName() + "被喚醒");
        });
        thread.start();
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        LockSupport.unpark(thread);
    }
}

thread線程調用LockSupport.park()致使thread阻塞，當mian線程睡眠3秒結束后通過LockSupport.unpark(thread)方法喚醒thread線程,thread線程被喚醒執(zhí)行后續(xù)操作。另外，還有一點值得關注的是，LockSupport.unpark(thread)可以指定線程對象喚醒指定的線程。