LockSupport源碼閱讀

CastlePeaK 發布于2019-08-16 10:35 / 3347人閱讀

摘要：源碼閱讀創建鎖和同步類中使用的基礎的線程阻塞原語除非你是多線程專家，而且你要自己設計和實現阻塞式線程同步機制比如等等，否則你不需要用和。

LockSupport源碼閱讀

/*
* 創建鎖和同步類中使用的基礎的線程阻塞原語
*  
* 除非你是多線程專家，而且你要自己設計和實現阻塞式線程同步機制（比如lock、condition等等），否則你不需要用park和unpark。這兩個原語是用來實現這些的，不是給應用程序用的
*/
public class LockSupport {
    //私有構造方法，不能被實例化
    private LockSupport() {} 
    //把 Thread 實例 t 的 parkBlocker 字段的值設置為 arg
    private static void setBlocker(Thread t, Object arg) {
       UNSAFE.putObject(t, parkBlockerOffset, arg);
    }

    /**
     * 如果給定線程的許可不可用，使其可用。
     * 如果線程在 park上受阻塞，則它將解除其阻塞狀態。否則，保證下一次調
     * 用 park 不會受阻塞。
     * 如果給定線程尚未啟動，則無法保證此操作有任何效果。 
     */
    public static void unpark(Thread thread) {
        if (thread != null)
            UNSAFE.unpark(thread);
    }


    public static void park(Object blocker) {
        Thread t = Thread.currentThread();
        setBlocker(t, blocker);
        UNSAFE.park(false, 0L);
        setBlocker(t, null);
    }

    /**
     * 帶超時時間的park
     */
    public static void parkNanos(Object blocker, long nanos) {
        if (nanos > 0) {
            Thread t = Thread.currentThread();
            setBlocker(t, blocker);
            UNSAFE.park(false, nanos);
            setBlocker(t, null);
        }
    }

    /**
     * 在deadline時間內，park
     */
    public static void parkUntil(Object blocker, long deadline) {
        Thread t = Thread.currentThread();
        setBlocker(t, blocker);
        UNSAFE.park(true, deadline);
        setBlocker(t, null);
    }

    /**
     * 返回提供給最近一次尚未解除阻塞的 park 方法調用的 blocker 對象，如果該調用不受阻塞，則返回 null。
     * 返回的值只是一個瞬間快照，即由于未解除阻塞或者在不同的 blocker 對象上受阻而具有的線程。
     */
    public static Object getBlocker(Thread t) {
        if (t == null)
            throw new NullPointerException();
        return UNSAFE.getObjectVolatile(t, parkBlockerOffset);
    }

    /**
     * 為了線程調度，禁用當前線程，除非有許可
     * 如果許可可用，使用改許可，且調用立即返回。否則，為進程調度禁用當前      * 線程，直到發生以下三件事之前一直休眠
     *
     * 1、其它線程觸發當前線程的unpark
     * 2、其它線程中斷當前線程
     * 3、毫無邏輯的返回
     * 此方法不返回誰引起此方法返回，調用方應該重新檢查誰最先park此線程，      * 調用方也可以決定此線程返回時的中斷狀態
      */
    public static void park() {
        UNSAFE.park(false, 0L);
    }

    /**
     * 帶超時時間的park
     */
    public static void parkNanos(long nanos) {
        if (nanos > 0)
            UNSAFE.park(false, nanos);
    }

    /**
     * 在deadline時間內，park
     */
    public static void parkUntil(long deadline) {
        UNSAFE.park(true, deadline);
    }

    /**
     * Returns the pseudo-randomly initialized or updated secondary seed.
     * Copied from ThreadLocalRandom due to package access restrictions.
     */
    static final int nextSecondarySeed() {
        int r;
        Thread t = Thread.currentThread();
        if ((r = UNSAFE.getInt(t, SECONDARY)) != 0) {
            r ^= r << 13;   // xorshift
            r ^= r >>> 17;
            r ^= r << 5;
        }
        else if ((r = java.util.concurrent.ThreadLocalRandom.current().nextInt()) == 0)
            r = 1; // avoid zero
        UNSAFE.putInt(t, SECONDARY, r);
        return r;
    }

    //引用Unsafe類
    private static final sun.misc.Unsafe UNSAFE;
    //Thread類中　parkBlocker 　字段的偏移量
    private static final long parkBlockerOffset;
    //Thread　類中　threadLocalRandomSeed　字段的偏移量
    private static final long SEED;
    //Thread　類中　threadLocalRandomProbe　字段的偏移量
    private static final long PROBE;
    //Thread　類中　threadLocalRandomSecondarySeed　字段的偏移量
    private static final long SECONDARY;
     //初始化上面4個字段的值
    static {
        try {
            UNSAFE = sun.misc.Unsafe.getUnsafe();
            Class tk = Thread.class;
            parkBlockerOffset = UNSAFE.objectFieldOffset
                (tk.getDeclaredField("parkBlocker"));
            SEED = UNSAFE.objectFieldOffset
                (tk.getDeclaredField("threadLocalRandomSeed"));
            PROBE = UNSAFE.objectFieldOffset
                (tk.getDeclaredField("threadLocalRandomProbe"));
            SECONDARY = UNSAFE.objectFieldOffset
                (tk.getDeclaredField("threadLocalRandomSecondarySeed"));
        } catch (Exception ex) { throw new Error(ex); }
    }

參考：Java的LockSupport.park()實現分析
使用方法：LockSupport的使用

GPU云服務器云服務器源碼閱讀 webrtc源碼閱讀 hbase源碼閱讀如何閱讀java源碼

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/70071.html

Thread源碼閱讀

摘要：中斷狀態可以通過來讀取，并且可以通過一個名為的操作讀取和清除。中斷的協作特性所帶來的一個好處是，它為安全地構造可取消活動提供更大的靈活性。中斷允許一個可取消活動來清理正在進行的工作，恢復不變量，通知其他活動它要被取消，然后才終止。 Thread實現Runnable接口 1.Thread內部有個State枚舉，標示著線程的狀態。 NEW，新建未開始 RUNNABLE，可執行 BLOCK...

isLishude 2019-08-16 10:34 評論0 收藏0
ConditionObject源碼閱讀

摘要：前言本來準備做源碼閱讀的幾千行看著太累了看了幾篇大神的文章后才基本搞懂附在這里閱讀本文前請先看懂的介紹和原理分析并發包源碼學習之框架四源碼分析接口實現接口一般看一個類實現的接口可以看出它的目的其實也是熟悉的目的主要是替代的方法的它是基于實現前言本來準備做AbstractQueuedSynchronizer源碼閱讀的,幾千行看著太累了,看了幾篇大神的文章后才基本搞懂,附在這里,閱讀本...

xietao3 2019-08-16 10:36 評論0 收藏0
LockSupport原理分析

摘要：此對象在線程受阻塞時被記錄，以允許監視工具和診斷工具確定線程受阻塞的原因。調用該線程變量的方法，會喚醒該線程，并拋出異常。對于等待狀態來說，它比狀態多了一種喚醒方式，就是超過規定時間，那么線程會自動醒來。一. LockSupport類介紹 LockSupport類可以阻塞當前線程以及喚醒指定被阻塞的線程。主要是通過park()和unpark(thread)方法來實現阻塞和喚醒線程的操...

phoenixsky 2019-08-15 15:31 評論0 收藏0
淺談Java并發編程系列（八）—— LockSupport原理剖析

摘要：此對象在線程受阻塞時被記錄，以允許監視工具和診斷工具確定線程受阻塞的原因。阻塞當前線程，最長不超過納秒，返回條件在的基礎上增加了超時返回。喚醒線程喚醒處于阻塞狀態的線程。 LockSupport 用法簡介 LockSupport 和 CAS 是Java并發包中很多并發工具控制機制的基礎，它們底層其實都是依賴Unsafe實現。 LockSupport是用來創建鎖和其他同步類的基本線程阻塞...

jeyhan 2019-08-14 17:36 評論0 收藏0
并發數據結構與線程（ArrayBlockingQueue）

摘要：今天在群上拋出來一個問題，如下我以自帶的數據結構為例，用源碼的形式說明，如何阻塞線程通知線程的。一以可重入鎖和兩個對象來控制并發。四使用來控制并發，同時也使用的對象來與線程交互。今天在QQ群上拋出來一個問題，如下showImg(https://segmentfault.com/img/bV1dEB?w=422&h=132); 我以Java自帶的數據結構為例，用源碼的形式說明，如何阻塞...

yck 2019-08-15 13:25 評論0 收藏0