快捷導(dǎo)航

Java多線程中的互斥鎖解析

更新時(shí)間：2023年09月15日 11:06:07 作者：伊顰伊笑

這篇文章主要介紹了Java多線程中的互斥鎖解析,Java語言中,引入了對象互斥鎖的概念,來保證共享數(shù)據(jù)操作的完整性,每個(gè)對象都對應(yīng)于一個(gè)可稱為互斥鎖的標(biāo)記,這個(gè)標(biāo)記用來保證在任一時(shí)刻,只能有一個(gè)線程訪問該對象,需要的朋友可以參考下

基本介紹

Java語言中，引入了對象互斥鎖的概念，來保證共享數(shù)據(jù)操作的完整性。
每個(gè)對象都對應(yīng)于一個(gè)可稱為 “ 互斥鎖 ” 的標(biāo)記，這個(gè)標(biāo)記用來保證在任一時(shí)刻，只能有一個(gè)線程訪問該對象。
關(guān)鍵字 synchronized 來與對象的互斥鎖聯(lián)系。當(dāng)某個(gè)對象用 synchronized 修飾時(shí)，表明該對象在任一時(shí)刻只能由一個(gè)線程訪問
同步的局限性：導(dǎo)致程序的執(zhí)行效率要降低
同步方法（非靜態(tài)的）的鎖可以是this，也可以是其他對象（要求是同一個(gè)對象）
同步方法（靜態(tài)的）的鎖為當(dāng)前類本身。

把 synchronized 寫在代碼塊上

package thread_;
/**
 * @Author: Gin
 * @Description:
 * @Modified By: Gin
 * @Date: Created in 16:37 2021/9/27
 */
public class Thread11 {
    public static void main(String[] args) {
        SellThread04 sellThread04 = new SellThread04();
        new Thread(sellThread04).start();
        new Thread(sellThread04).start();
        new Thread(sellThread04).start();
    }
}
class SellThread04 implements Runnable{
    private int ticketsNum = 100;
    private boolean flag = true;
    @Override
    public void run() {
        while (flag) {
            sell();
        }
    }
    /*
        1. public synchronized void sell(){} 就是一個(gè)同步方法
        2. 這時(shí)“鎖”在 this 對象上
        3. 也可以在代碼塊上寫 synchronized，同步代碼塊，互斥鎖還是在 this 對象上
           如下：
     */
    public /* synchronized */ void sell(){
        synchronized (this) {
            if(ticketsNum <= 0){
                System.out.println("售票結(jié)束...");
                flag = false;
                return;
            }
            try {
                Thread.sleep(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("窗口 " + Thread.currentThread().getName() + " 售票一張， 剩余票數(shù) " + (--ticketsNum));
        }
    }
}

測試操作同一個(gè)對象、靜態(tài)方法的鎖的添加

package thread_;
/**
 * @Author: Gin
 * @Description:
 * @Modified By: Gin
 * @Date: Created in 16:37 2021/9/27
 */
public class Thread11 {
    public static void main(String[] args) {
        SellThread04 sellThread04 = new SellThread04();
        new Thread(sellThread04).start();
        new Thread(sellThread04).start();
        new Thread(sellThread04).start();
    }
}
class SellThread04 implements Runnable{
    private int ticketsNum = 100;
    private boolean flag = true;
    // 同步方法（非靜態(tài)的）的鎖可以是this，也可以是其他對象（要求是同一個(gè)對象）
    // new 一個(gè) Object 對象，測試操作同一個(gè)對象
    Object object = new Object();
    // 同步方法（靜態(tài)的）的鎖為當(dāng)前類本身。
    public synchronized static void m1(){
        System.out.println("m1");
    }
    // 在靜態(tài)方法中實(shí)現(xiàn)一個(gè)同步代碼塊
    public static void m2(){
        synchronized (SellThread04.class) {
            System.out.println("m2");
        }
    }
    @Override
    public void run() {
        while (flag) {
            sell();
        }
    }
    /*
        1. public synchronized void sell(){} 就是一個(gè)同步方法
        2. 這時(shí)“鎖”在 this 對象上
        3. 也可以在代碼塊上寫 synchronized，同步代碼塊，互斥鎖還是在 this 對象上
           如下：
     */
    public /* synchronized */ void sell(){
        synchronized ( /*this*/ object ) { // 測試操作同一個(gè)對象
            if(ticketsNum <= 0){
                System.out.println("售票結(jié)束...");
                flag = false;
                return;
            }
            try {
                Thread.sleep(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("窗口 " + Thread.currentThread().getName() + " 售票一張， 剩余票數(shù) " + (--ticketsNum));
        }
    }
}

細(xì)節(jié)

同步方法如果沒有使用 static 修飾：默認(rèn)鎖對象為 this如果方法使用 static 修飾，默認(rèn)鎖對象：當(dāng)前類.class

到此這篇關(guān)于Java多線程中的互斥鎖解析的文章就介紹到這了,更多相關(guān)Java互斥鎖內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: