java中怎么實(shí)現(xiàn)可重入的自旋鎖

這篇文章主要介紹了java中怎么實(shí)現(xiàn)可重入的自旋鎖的相關(guān)知識，內(nèi)容詳細(xì)易懂，操作簡單快捷，具有一定借鑒價(jià)值，相信大家閱讀完這篇java中怎么實(shí)現(xiàn)可重入的自旋鎖文章都會有所收獲，下面我們一起來看看吧。

說明

1、是指試圖獲得鎖的線程不會堵塞，而是通過循環(huán)獲得鎖。

2、優(yōu)點(diǎn)：減少上下文切換的消耗。

缺點(diǎn)：循環(huán)消耗CPU。

實(shí)例

public class ReentrantSpinLock {
 
 
    private AtomicReference<Thread> owner = new AtomicReference<>();
 
    // 可重入次數(shù)
    private int count = 0;
 
    // 加鎖
    public void lock() {
        Thread current = Thread.currentThread();
        if (owner.get() == current) {
            count++;
            return;
        }
        while (!owner.compareAndSet(null, current)) {
            System.out.println("--我在自旋--");
        }
    }
 
    //解鎖
    public void unLock() {
        Thread current = Thread.currentThread();
        //只有持有鎖的線程才能解鎖
        if (owner.get() == current) {
            if (count > 0) {
                count--;
            } else {
                //此處無需CAS操作，因?yàn)闆]有競爭，因?yàn)橹挥芯€程持有者才能解鎖
                owner.set(null);
            }
        }
    }
 
    public static void main(String[] args) {
        ReentrantSpinLock spinLock = new ReentrantSpinLock();
        Runnable runnable = () -> {
            System.out.println(Thread.currentThread().getName() + "開始嘗試獲取自旋鎖");
            spinLock.lock();
            try {
                System.out.println(Thread.currentThread().getName() + "獲取到了自旋鎖");
                Thread.sleep(4000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                spinLock.unLock();
                System.out.println(Thread.currentThread().getName() + "釋放了了自旋鎖");
            }
        };
        Thread thread1 = new Thread(runnable);
        Thread thread2 = new Thread(runnable);
        thread1.start();
        thread2.start();
    }
}

關(guān)于“java中怎么實(shí)現(xiàn)可重入的自旋鎖”這篇文章的內(nèi)容就介紹到這里，感謝各位的閱讀！相信大家對“java中怎么實(shí)現(xiàn)可重入的自旋鎖”知識都有一定的了解，大家如果還想學(xué)習(xí)更多知識，歡迎關(guān)注億速云行業(yè)資訊頻道。