快捷導(dǎo)航

Java多線(xiàn)程+鎖機(jī)制實(shí)現(xiàn)簡(jiǎn)單模擬搶票的項(xiàng)目實(shí)踐

更新時(shí)間：2024年02月03日 09:42:18 作者：帥龍之龍

鎖是一種同步機(jī)制,用于控制對(duì)共享資源的訪(fǎng)問(wèn),在線(xiàn)程獲取到鎖對(duì)象后,可以執(zhí)行搶票操作,本文主要介紹了Java多線(xiàn)程+鎖機(jī)制實(shí)現(xiàn)簡(jiǎn)單模擬搶票的項(xiàng)目實(shí)踐,具有一定的參考價(jià)值,感興趣的可以了解一下

前言

鎖是一種同步機(jī)制，用于控制對(duì)共享資源的訪(fǎng)問(wèn)。鎖的作用是確保同一時(shí)間只有一個(gè)線(xiàn)程可以訪(fǎng)問(wèn)共享資源，也就是說(shuō)保證了線(xiàn)程安全。因此在并發(fā)編程中，鎖是相當(dāng)重要的。

一、基本概念

1.為什么需要鎖？

（1）多任務(wù)環(huán)境中才需要；
（2）任務(wù)都需要對(duì)同一共享資源進(jìn)行寫(xiě)操作；
（3）對(duì)資源的訪(fǎng)問(wèn)是互斥的；

2.Syncronized與Lock的區(qū)別

（1）syncronized是jvm層面的內(nèi)置關(guān)鍵字，lock是java的一個(gè)接口；
（2）syncronized實(shí)現(xiàn)線(xiàn)程同步時(shí)，若線(xiàn)程一阻塞，線(xiàn)程二則一直等待，lock則不會(huì)，會(huì)自動(dòng)結(jié)束線(xiàn)程；
（3）syncronized會(huì)自動(dòng)釋放鎖，lock需要手動(dòng)在finally里釋放（unlock），syncronized無(wú)法判斷是否獲得鎖的狀態(tài)，lock可以；
（4）syncronized的鎖可重入、不可中斷、非公平，lock的鎖可重入、可中斷、公平；
（5）lock適合大量同步代碼的同步問(wèn)題，syncronized適合少量；

3.常見(jiàn)的鎖

（1）sychronized：非公平、悲觀(guān)、獨(dú)享、互斥、可重入的重量級(jí)鎖
（2）ReentrantLock：默認(rèn)非公平但可實(shí)現(xiàn)公平的、悲觀(guān)、獨(dú)享、互斥、可重入、重量級(jí)鎖
（3）ReentrantReadWriteLock：默認(rèn)非公平但是可實(shí)現(xiàn)公平的、悲觀(guān)、寫(xiě)?yīng)毾怼⒆x共享、讀寫(xiě)、可重入、重量級(jí)鎖

4.缺點(diǎn)

jvm鎖解決不了分布式環(huán)境多任務(wù)對(duì)共享資源競(jìng)爭(zhēng)的協(xié)同操作問(wèn)題。

二、模擬搶票

（1）不用鎖的情況，會(huì)出現(xiàn)重賣(mài)問(wèn)題，應(yīng)避免重賣(mài)還有超賣(mài)問(wèn)題

public class Main {
    public static void main(String[] args) {
        DiyThread diyThread = new DiyThread();
        Thread t1 = new Thread(diyThread,"窗口A");
        Thread t2 = new Thread(diyThread,"窗口B");
        Thread t3 = new Thread(diyThread,"窗口C");
        Thread t4 = new Thread(diyThread,"窗口D");
        t1.start();
        t2.start();
        t3.start();
        t4.start();
    }
}

class DiyThread implements Runnable {
    // 成員變量(實(shí)例變量)：隨著對(duì)象的創(chuàng)建而存在，隨著對(duì)象的回收而釋放，存儲(chǔ)在堆內(nèi)存的對(duì)象中
    private int count = 100;

    // 靜態(tài)變量(類(lèi)變量)：隨著類(lèi)的加載而存在，隨著類(lèi)的消失而消失，存儲(chǔ)在方法區(qū)(共享數(shù)據(jù)區(qū))的靜態(tài)區(qū)
    // private static int count = 100;

    public void run() {
        while (true) {
            if (count > 0) {
                // 不用鎖的情況，會(huì)出現(xiàn)重賣(mài)問(wèn)題
                System.out.println(Thread.currentThread().getName() + " -> 售出第" + count + "張火車(chē)票");
                count--;
                try {
                    // 睡眠50毫秒
                    Thread.sleep(50);
                } catch (Exception e) {
                    System.out.println(Thread.currentThread().getName() + " : 出現(xiàn)異常 -> " + e.getMessage());
                }
            } else {
                System.out.println(Thread.currentThread().getName() + " : 票已售完");
                break;
            }
        }
    }
}

（2）使用【同步代碼塊】使線(xiàn)程串行同步，不然會(huì)出現(xiàn)線(xiàn)程不安全的問(wèn)題

public class Main {
    public static void main(String[] args) {
        DiyThread diyThread = new DiyThread();
        Thread t1 = new Thread(diyThread,"窗口A");
        Thread t2 = new Thread(diyThread,"窗口B");
        Thread t3 = new Thread(diyThread,"窗口C");
        Thread t4 = new Thread(diyThread,"窗口D");
        t1.start();
        t2.start();
        t3.start();
        t4.start();
    }
}

class DiyThread implements Runnable {
    // 成員變量(實(shí)例變量)：隨著對(duì)象的創(chuàng)建而存在，隨著對(duì)象的回收而釋放，存儲(chǔ)在堆內(nèi)存的對(duì)象中
    private int count = 100;

    // 靜態(tài)變量(類(lèi)變量)：隨著類(lèi)的加載而存在，隨著類(lèi)的消失而消失，存儲(chǔ)在方法區(qū)(共享數(shù)據(jù)區(qū))的靜態(tài)區(qū)
    // private static int count = 100;

    public void run() {
        while (true) {
            synchronized(this) {
                if (count > 0) {
                    System.out.println(Thread.currentThread().getName() + " -> 售出第" + count + "張火車(chē)票");
                    count--;
                    try {
                        // 睡眠50毫秒
                        Thread.sleep(50);
                    } catch (Exception e) {
                        System.out.println(Thread.currentThread().getName() + " : 出現(xiàn)異常 -> " + e.getMessage());
                    }
                } else {
                    System.out.println(Thread.currentThread().getName() + " : 票已售完");
                    break;
                }
            }
        }
    }
}

（3）使用【synchronized】同步函數(shù)使線(xiàn)程串行同步，不然會(huì)出現(xiàn)線(xiàn)程不安全的問(wèn)題

public class Main {
    public static void main(String[] args) {
        DiyThread diyThread = new DiyThread();
        Thread t1 = new Thread(diyThread,"窗口A");
        Thread t2 = new Thread(diyThread,"窗口B");
        Thread t3 = new Thread(diyThread,"窗口C");
        Thread t4 = new Thread(diyThread,"窗口D");
        t1.start();
        t2.start();
        t3.start();
        t4.start();
    }
}

class DiyThread implements Runnable {
    // 成員變量(實(shí)例變量)：隨著對(duì)象的創(chuàng)建而存在，隨著對(duì)象的回收而釋放，存儲(chǔ)在堆內(nèi)存的對(duì)象中
    private int count = 100;

    // 靜態(tài)變量(類(lèi)變量)：隨著類(lèi)的加載而存在，隨著類(lèi)的消失而消失，存儲(chǔ)在方法區(qū)(共享數(shù)據(jù)區(qū))的靜態(tài)區(qū)
    // private static int count = 100;

    public void run() {
        sale();
    }

    private synchronized void sale() {
        while (true) {
            if (count > 0) {
                System.out.println(Thread.currentThread().getName() + " -> 售出第" + count + "張火車(chē)票");
                count--;
                try {
                    // 睡眠50毫秒
                    Thread.sleep(50);
                } catch (Exception e) {
                    System.out.println(Thread.currentThread().getName() + " : 出現(xiàn)異常 -> " + e.getMessage());
                }
            } else {
                System.out.println(Thread.currentThread().getName() + " : 票已售完");
                break;
            }
        }
    }
}

（4）使用【java.util.concurrent】簡(jiǎn)稱(chēng)juc包的lock鎖

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class Main {
    public static void main(String[] args) {
        DiyThread diyThread = new DiyThread();
        Thread t1 = new Thread(diyThread,"窗口A");
        Thread t2 = new Thread(diyThread,"窗口B");
        Thread t3 = new Thread(diyThread,"窗口C");
        Thread t4 = new Thread(diyThread,"窗口D");
        t1.start();
        t2.start();
        t3.start();
        t4.start();
    }
}

class DiyThread implements Runnable {
    // 成員變量(實(shí)例變量)：隨著對(duì)象的創(chuàng)建而存在，隨著對(duì)象的回收而釋放，存儲(chǔ)在堆內(nèi)存的對(duì)象中
    private int count = 100;

    // 靜態(tài)變量(類(lèi)變量)：隨著類(lèi)的加載而存在，隨著類(lèi)的消失而消失，存儲(chǔ)在方法區(qū)(共享數(shù)據(jù)區(qū))的靜態(tài)區(qū)
    // private static int count = 100;

    private Lock lock = new ReentrantLock();

    public void run() {
        while (true) {
            lock.lock(); // 加鎖之后，以下的業(yè)務(wù)代碼就是單線(xiàn)程環(huán)境運(yùn)行，如4個(gè)線(xiàn)程競(jìng)爭(zhēng)這把鎖
            try {
                if (count > 0) {
                    System.out.println(Thread.currentThread().getName() + " -> 售出第" + count + "張火車(chē)票");
                    count--;
                    Thread.sleep(50);
                } else {
                    System.out.println(Thread.currentThread().getName() + " : 票已售完");
                    break;
                }
            } catch (Exception e) {
                System.out.println(Thread.currentThread().getName() + " : 出現(xiàn)異常 -> " + e.getMessage());
            } finally {
                lock.unlock(); // 解鎖，最重要原因?yàn)楸苊馑梨i，無(wú)論正確、異常執(zhí)行，都執(zhí)行解鎖
            }
        }
    }
}

到此這篇關(guān)于Java多線(xiàn)程+鎖機(jī)制實(shí)現(xiàn)簡(jiǎn)單模擬搶票的項(xiàng)目實(shí)踐的文章就介紹到這了,更多相關(guān)Java 模擬搶票內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: