synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么

本文小編為大家詳細(xì)介紹“synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么”,內(nèi)容詳細(xì),步驟清晰,細(xì)節(jié)處理妥當(dāng),希望這篇“synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么”文章能幫助大家解決疑惑,下面跟著小編的思路慢慢深入,一起來學(xué)習(xí)新知識(shí)吧。

10年積累的成都網(wǎng)站設(shè)計(jì)、網(wǎng)站制作經(jīng)驗(yàn),可以快速應(yīng)對(duì)客戶對(duì)網(wǎng)站的新想法和需求。提供各種問題對(duì)應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認(rèn)識(shí)你,你也不認(rèn)識(shí)我。但先做網(wǎng)站設(shè)計(jì)后付款的網(wǎng)站建設(shè)流程,更有湖北免費(fèi)網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。

1. synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化?

synchronized的實(shí)現(xiàn)原理

  • synchronized作用于「方法」或者「代碼塊」,保證被修飾的代碼在同一時(shí)間只能被一個(gè)線程訪問。

  • synchronized修飾代碼塊時(shí),JVM采用「monitorenter、monitorexit」兩個(gè)指令來實(shí)現(xiàn)同步

  • synchronized修飾同步方法時(shí),JVM采用「ACC_SYNCHRONIZED」標(biāo)記符來實(shí)現(xiàn)同步

  • monitorenter、monitorexit或者ACC_SYNCHRONIZED都是「基于Monitor實(shí)現(xiàn)」

  • 實(shí)例對(duì)象里有對(duì)象頭,對(duì)象頭里面有Mark Word,Mark Word指針指向了「monitor」

  • Monitor其實(shí)是一種「同步工具」,也可以說是一種「同步機(jī)制」。

  • 在Java虛擬機(jī)(HotSpot)中,Monitor是由「ObjectMonitor實(shí)現(xiàn)」的。ObjectMonitor體現(xiàn)出Monitor的工作原理~

ObjectMonitor() {
    _header       = NULL;
    _count        = 0; // 記錄線程獲取鎖的次數(shù)
    _waiters      = 0,
    _recursions   = 0;  //鎖的重入次數(shù)
    _object       = NULL;
    _owner        = NULL;  // 指向持有ObjectMonitor對(duì)象的線程
    _WaitSet      = NULL;  // 處于wait狀態(tài)的線程,會(huì)被加入到_WaitSet
    _WaitSetLock  = 0 ;
    _Responsible  = NULL ;
    _succ         = NULL ;
    _cxq          = NULL ;
    FreeNext      = NULL ;
    _EntryList    = NULL ;  // 處于等待鎖block狀態(tài)的線程,會(huì)被加入到該列表
    _SpinFreq     = 0 ;
    _SpinClock    = 0 ;
    OwnerIsThread = 0 ;
  }
復(fù)制代碼

ObjectMonitor的幾個(gè)關(guān)鍵屬性 count、recursions、owner、WaitSet、 _EntryList 體現(xiàn)了monitor的工作原理

synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么

鎖優(yōu)化

在討論鎖優(yōu)化前,先看看JAVA對(duì)象頭(32位JVM)中Mark Word的結(jié)構(gòu)圖吧~

synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么

Mark Word存儲(chǔ)對(duì)象自身的運(yùn)行數(shù)據(jù),如「哈希碼、GC分代年齡、鎖狀態(tài)標(biāo)志、偏向時(shí)間戳(Epoch)」等,為什么區(qū)分「偏向鎖、輕量級(jí)鎖、重量級(jí)鎖」等幾種鎖狀態(tài)呢?

?

在JDK1.6之前,synchronized的實(shí)現(xiàn)直接調(diào)用ObjectMonitor的enter和exit,這種鎖被稱之為「重量級(jí)鎖」。從JDK6開始,HotSpot虛擬機(jī)開發(fā)團(tuán)隊(duì)對(duì)Java中的鎖進(jìn)行優(yōu)化,如增加了適應(yīng)性自旋、鎖消除、鎖粗化、輕量級(jí)鎖和偏向鎖等優(yōu)化策略。

?

  • 偏向鎖:在無競爭的情況下,把整個(gè)同步都消除掉,CAS操作都不做。

  • 輕量級(jí)鎖:在沒有多線程競爭時(shí),相對(duì)重量級(jí)鎖,減少操作系統(tǒng)互斥量帶來的性能消耗。但是,如果存在鎖競爭,除了互斥量本身開銷,還額外有CAS操作的開銷。

  • 自旋鎖:減少不必要的CPU上下文切換。在輕量級(jí)鎖升級(jí)為重量級(jí)鎖時(shí),就使用了自旋加鎖的方式

  • 鎖粗化:將多個(gè)連續(xù)的加鎖、解鎖操作連接在一起,擴(kuò)展成一個(gè)范圍更大的鎖。

?

舉個(gè)例子,買門票進(jìn)動(dòng)物園。老師帶一群小朋友去參觀,驗(yàn)票員如果知道他們是個(gè)集體,就可以把他們看成一個(gè)整體(鎖租化),一次性驗(yàn)票過,而不需要一個(gè)個(gè)找他們驗(yàn)票。

?

  • 鎖消除:虛擬機(jī)即時(shí)編譯器在運(yùn)行時(shí),對(duì)一些代碼上要求同步,但是被檢測到不可能存在共享數(shù)據(jù)競爭的鎖進(jìn)行消除。

有興趣的朋友們可以看看我這篇文章: Synchronized解析——如果你愿意一層一層剝開我的心[1]

2. ThreadLocal原理,使用注意點(diǎn),應(yīng)用場景有哪些?

回答四個(gè)主要點(diǎn):

  • ThreadLocal是什么?

  • ThreadLocal原理

  • ThreadLocal使用注意點(diǎn)

  • ThreadLocal的應(yīng)用場景

ThreadLocal是什么?

ThreadLocal,即線程本地變量。如果你創(chuàng)建了一個(gè)ThreadLocal變量,那么訪問這個(gè)變量的每個(gè)線程都會(huì)有這個(gè)變量的一個(gè)本地拷貝,多個(gè)線程操作這個(gè)變量的時(shí)候,實(shí)際是操作自己本地內(nèi)存里面的變量,從而起到線程隔離的作用,避免了線程安全問題。

//創(chuàng)建一個(gè)ThreadLocal變量
static ThreadLocal<String> localVariable = new ThreadLocal<>();
復(fù)制代碼

ThreadLocal原理

ThreadLocal內(nèi)存結(jié)構(gòu)圖:

synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么

由結(jié)構(gòu)圖是可以看出:

  • Thread對(duì)象中持有一個(gè)ThreadLocal.ThreadLocalMap的成員變量。

  • ThreadLocalMap內(nèi)部維護(hù)了Entry數(shù)組,每個(gè)Entry代表一個(gè)完整的對(duì)象,key是ThreadLocal本身,value是ThreadLocal的泛型值。

對(duì)照這幾段關(guān)鍵源碼來看,更容易理解一點(diǎn)哈~

public class Thread implements Runnable {
   //ThreadLocal.ThreadLocalMap是Thread的屬性
   ThreadLocal.ThreadLocalMap threadLocals = null;
}
復(fù)制代碼

ThreadLocal中的關(guān)鍵方法set()和get()

   public void set(T value) {
        Thread t = Thread.currentThread(); //獲取當(dāng)前線程t
        ThreadLocalMap map = getMap(t);  //根據(jù)當(dāng)前線程獲取到ThreadLocalMap
        if (map != null)
            map.set(this, value); //K,V設(shè)置到ThreadLocalMap中
        else
            createMap(t, value); //創(chuàng)建一個(gè)新的ThreadLocalMap
    }

    public T get() {
        Thread t = Thread.currentThread();//獲取當(dāng)前線程t
        ThreadLocalMap map = getMap(t);//根據(jù)當(dāng)前線程獲取到ThreadLocalMap
        if (map != null) {
            //由this(即ThreadLoca對(duì)象)得到對(duì)應(yīng)的Value,即ThreadLocal的泛型值
            ThreadLocalMap.Entry e = map.getEntry(this);
            if (e != null) {
                @SuppressWarnings("unchecked")
                T result = (T)e.value; 
                return result;
            }
        }
        return setInitialValue();
    }
復(fù)制代碼

ThreadLocalMap的Entry數(shù)組

static class ThreadLocalMap {
    static class Entry extends WeakReference<ThreadLocal<?>> {
        /** The value associated with this ThreadLocal. */
        Object value;

        Entry(ThreadLocal<?> k, Object v) {
            super(k);
            value = v;
        }
    }
}
復(fù)制代碼

所以怎么回答「ThreadLocal的實(shí)現(xiàn)原理」?如下,最好是能結(jié)合以上結(jié)構(gòu)圖一起說明哈~

? Thread類有一個(gè)類型為ThreadLocal.ThreadLocalMap的實(shí)例變量threadLocals,即每個(gè)線程都有一個(gè)屬于自己的ThreadLocalMap。ThreadLocalMap內(nèi)部維護(hù)著Entry數(shù)組,每個(gè)Entry代表一個(gè)完整的對(duì)象,key是ThreadLocal本身,value是ThreadLocal的泛型值。每個(gè)線程在往ThreadLocal里設(shè)置值的時(shí)候,都是往自己的ThreadLocalMap里存,讀也是以某個(gè)ThreadLocal作為引用,在自己的map里找對(duì)應(yīng)的key,從而實(shí)現(xiàn)了線程隔離。 ?

ThreadLocal 內(nèi)存泄露問題

先看看一下的TreadLocal的引用示意圖哈,

synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么

ThreadLocalMap中使用的 key 為 ThreadLocal 的弱引用,如下

synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么

?

弱引用:只要垃圾回收機(jī)制一運(yùn)行,不管JVM的內(nèi)存空間是否充足,都會(huì)回收該對(duì)象占用的內(nèi)存。

?

弱引用比較容易被回收。因此,如果ThreadLocal(ThreadLocalMap的Key)被垃圾回收器回收了,但是因?yàn)門hreadLocalMap生命周期和Thread是一樣的,它這時(shí)候如果不被回收,就會(huì)出現(xiàn)這種情況:ThreadLocalMap的key沒了,value還在,這就會(huì)「造成了內(nèi)存泄漏問題」

如何「解決內(nèi)存泄漏問題」?使用完ThreadLocal后,及時(shí)調(diào)用remove()方法釋放內(nèi)存空間。

ThreadLocal的應(yīng)用場景

  • 數(shù)據(jù)庫連接池

  • 會(huì)話管理中使用

3. synchronized和ReentrantLock的區(qū)別?

我記得校招的時(shí)候,這道面試題出現(xiàn)的頻率還是挺高的~可以從鎖的實(shí)現(xiàn)、功能特點(diǎn)、性能等幾個(gè)維度去回答這個(gè)問題,

  • 「鎖的實(shí)現(xiàn):」synchronized是Java語言的關(guān)鍵字,基于JVM實(shí)現(xiàn)。而ReentrantLock是基于JDK的API層面實(shí)現(xiàn)的(一般是lock()和unlock()方法配合try/finally 語句塊來完成。)

  • 「性能:」在JDK1.6鎖優(yōu)化以前,synchronized的性能比ReenTrantLock差很多。但是JDK6開始,增加了適應(yīng)性自旋、鎖消除等,兩者性能就差不多了。

  • 「功能特點(diǎn):」ReentrantLock 比 synchronized 增加了一些高級(jí)功能,如等待可中斷、可實(shí)現(xiàn)公平鎖、可實(shí)現(xiàn)選擇性通知。

? ReentrantLock提供了一種能夠中斷等待鎖的線程的機(jī)制,通過lock.lockInterruptibly()來實(shí)現(xiàn)這個(gè)機(jī)制。ReentrantLock可以指定是公平鎖還是非公平鎖。而synchronized只能是非公平鎖。所謂的公平鎖就是先等待的線程先獲得鎖。synchronized與wait()和notify()/notifyAll()方法結(jié)合實(shí)現(xiàn)等待/通知機(jī)制,ReentrantLock類借助Condition接口與newCondition()方法實(shí)現(xiàn)。ReentrantLock需要手工聲明來加鎖和釋放鎖,一般跟finally配合釋放鎖。而synchronized不用手動(dòng)釋放鎖。 ?

4. 說說CountDownLatch與CyclicBarrier區(qū)別

  • CountDownLatch:一個(gè)或者多個(gè)線程,等待其他多個(gè)線程完成某件事情之后才能執(zhí)行;

  • CyclicBarrier:多個(gè)線程互相等待,直到到達(dá)同一個(gè)同步點(diǎn),再繼續(xù)一起執(zhí)行。

synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么

舉個(gè)例子吧:

? CountDownLatch:假設(shè)老師跟同學(xué)約定周末在公園門口集合,等人齊了再發(fā)門票。那么,發(fā)門票(這個(gè)主線程),需要等各位同學(xué)都到齊(多個(gè)其他線程都完成),才能執(zhí)行。CyclicBarrier:多名短跑運(yùn)動(dòng)員要開始田徑比賽,只有等所有運(yùn)動(dòng)員準(zhǔn)備好,裁判才會(huì)鳴槍開始,這時(shí)候所有的運(yùn)動(dòng)員才會(huì)疾步如飛。 ?

5. Fork/Join框架的理解

?

Fork/Join框架是Java7提供的一個(gè)用于并行執(zhí)行任務(wù)的框架,是一個(gè)把大任務(wù)分割成若干個(gè)小任務(wù),最終匯總每個(gè)小任務(wù)結(jié)果后得到大任務(wù)結(jié)果的框架。

?

Fork/Join框架需要理解兩個(gè)點(diǎn),「分而治之」「工作竊取算法」。

「分而治之」

以上Fork/Join框架的定義,就是分而治之思想的體現(xiàn)啦

synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么

「工作竊取算法」

把大任務(wù)拆分成小任務(wù),放到不同隊(duì)列執(zhí)行,交由不同的線程分別執(zhí)行時(shí)。有的線程優(yōu)先把自己負(fù)責(zé)的任務(wù)執(zhí)行完了,其他線程還在慢慢悠悠處理自己的任務(wù),這時(shí)候?yàn)榱顺浞痔岣咝剩托枰ぷ鞅I竊算法啦~

synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么

工作盜竊算法就是,「某個(gè)線程從其他隊(duì)列中竊取任務(wù)進(jìn)行執(zhí)行的過程」。一般就是指做得快的線程(盜竊線程)搶慢的線程的任務(wù)來做,同時(shí)為了減少鎖競爭,通常使用雙端隊(duì)列,即快線程和慢線程各在一端。

6. 為什么我們調(diào)用start()方法時(shí)會(huì)執(zhí)行run()方法,為什么我們不能直接調(diào)用run()方法?

看看Thread的start方法說明哈~

   /**
     * Causes this thread to begin execution; the Java Virtual Machine
     * calls the <code>run</code> method of this thread.
     * <p>
     * The result is that two threads are running concurrently: the
     * current thread (which returns from the call to the
     * <code>start</code> method) and the other thread (which executes its
     * <code>run</code> method).
     * <p>
     * It is never legal to start a thread more than once.
     * In particular, a thread may not be restarted once it has completed
     * execution.
     *
     * @exception  IllegalThreadStateException  if the thread was already
     *               started.
     * @see        #run()
     * @see        #stop()
     */
    public synchronized void start() {
     ......
    }
復(fù)制代碼

JVM執(zhí)行start方法,會(huì)另起一條線程執(zhí)行thread的run方法,這才起到多線程的效果~ 「為什么我們不能直接調(diào)用run()方法?」如果直接調(diào)用Thread的run()方法,其方法還是運(yùn)行在主線程中,沒有起到多線程效果。

7. CAS?CAS 有什么缺陷,如何解決?

CAS,Compare and Swap,比較并交換;

?

CAS 涉及3個(gè)操作數(shù),內(nèi)存地址值V,預(yù)期原值A(chǔ),新值B; 如果內(nèi)存位置的值V與預(yù)期原A值相匹配,就更新為新值B,否則不更新

?

CAS有什么缺陷?

synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么

「ABA 問題」

?

并發(fā)環(huán)境下,假設(shè)初始條件是A,去修改數(shù)據(jù)時(shí),發(fā)現(xiàn)是A就會(huì)執(zhí)行修改。但是看到的雖然是A,中間可能發(fā)生了A變B,B又變回A的情況。此時(shí)A已經(jīng)非彼A,數(shù)據(jù)即使成功修改,也可能有問題。

?

可以通過AtomicStampedReference「解決ABA問題」,它,一個(gè)帶有標(biāo)記的原子引用類,通過控制變量值的版本來保證CAS的正確性。

「循環(huán)時(shí)間長開銷」

?

自旋CAS,如果一直循環(huán)執(zhí)行,一直不成功,會(huì)給CPU帶來非常大的執(zhí)行開銷。

?

很多時(shí)候,CAS思想體現(xiàn),是有個(gè)自旋次數(shù)的,就是為了避開這個(gè)耗時(shí)問題~

「只能保證一個(gè)變量的原子操作。」

?

CAS 保證的是對(duì)一個(gè)變量執(zhí)行操作的原子性,如果對(duì)多個(gè)變量操作時(shí),CAS 目前無法直接保證操作的原子性的。

?

可以通過這兩個(gè)方式解決這個(gè)問題:

? 使用互斥鎖來保證原子性;將多個(gè)變量封裝成對(duì)象,通過AtomicReference來保證原子性。 ?

有興趣的朋友可以看看我之前的這篇實(shí)戰(zhàn)文章哈~ CAS樂觀鎖解決并發(fā)問題的一次實(shí)踐[2]

8. 如何保證多線程下i++ 結(jié)果正確?

synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么

  • 使用循環(huán)CAS,實(shí)現(xiàn)i++原子操作

  • 使用鎖機(jī)制,實(shí)現(xiàn)i++原子操作

  • 使用synchronized,實(shí)現(xiàn)i++原子操作

沒有代碼demo,感覺是沒有靈魂的~ 如下:

/**
 *  @Author 撿田螺的小男孩
 */
public class AtomicIntegerTest {

    private static AtomicInteger atomicInteger = new AtomicInteger(0);

    public static void main(String[] args) throws InterruptedException {
        testIAdd();
    }

    private static void testIAdd() throws InterruptedException {
        //創(chuàng)建線程池
        ExecutorService executorService = Executors.newFixedThreadPool(2);
        for (int i = 0; i < 1000; i++) {
            executorService.execute(() -> {
                for (int j = 0; j < 2; j++) {
                    //自增并返回當(dāng)前值
                    int andIncrement = atomicInteger.incrementAndGet();
                    System.out.println("線程:">運(yùn)行結(jié)果:...
線程:pool-1-thread-1 count=1997
線程:pool-1-thread-1 count=1998
線程:pool-1-thread-1 count=1999
線程:pool-1-thread-2 count=315
線程:pool-1-thread-2 count=2000
最終結(jié)果是 :2000

讀到這里,這篇“synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么”文章已經(jīng)介紹完畢,想要掌握這篇文章的知識(shí)點(diǎn)還需要大家自己動(dòng)手實(shí)踐使用過才能領(lǐng)會(huì),如果想了解更多相關(guān)內(nèi)容的文章,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

網(wǎng)頁標(biāo)題:synchronized的實(shí)現(xiàn)原理以及鎖優(yōu)化方法是什么
網(wǎng)頁路徑:http://bm7419.com/article16/jjdjgg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站維護(hù)用戶體驗(yàn)、微信公眾號(hào)Google、網(wǎng)站建設(shè)、網(wǎng)站導(dǎo)航

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)

成都網(wǎng)頁設(shè)計(jì)公司