多線程(四)-線程同步

来源:https://www.cnblogs.com/xiaoqigui/archive/2022/06/21/16396916.html
-Advertisement-
Play Games

大佬的理解-> Java多線程(三)--synchronized關鍵字詳情 大佬的理解-> Java多線程(三)--synchronized關鍵字續 1、問題引入 買票問題 1.1 通過繼承Thread買票 繼承Thread買票案例 /* 模擬網路購票,多線程資源共用問題,繼承Thread方式; 結 ...


大佬的理解-> Java多線程(三)--synchronized關鍵字詳情

大佬的理解-> Java多線程(三)--synchronized關鍵字續

1、問題引入

買票問題

1.1 通過繼承Thread買票

繼承Thread買票案例

/*
    模擬網路購票,多線程資源共用問題,繼承Thread方式;
    結論:此種方式,不存在資源共用,通過創建對象啟動的線程,每個對象都有各自的屬性值
 */
public class MyThreadTicket extends Thread{

    //總票數
    private int remainSite = 100;

    //搶到的座位號
    private int buySite = 0;

    @Override
    public void run() {
        //模擬迴圈搶票
        while(true){
            //判斷餘票是否充足,如果不足,結束
            if(remainSite <= 0){
                break;
            }

            //更改強股票數據
            buySite++;
            remainSite--;

            //模擬網路延遲
            try {
                TimeUnit.MILLISECONDS.sleep(20);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            System.out.println(Thread.currentThread().getName()+"買到第"+buySite+"張票,剩餘"+remainSite+"張票");
        }
    }

    public static void main(String[] args) {
        //模擬三人同事搶票
        MyThreadTicket threadTicket1 = new MyThreadTicket();
        threadTicket1.setName("豬八戒");
        MyThreadTicket threadTicket2 = new MyThreadTicket();
        threadTicket2.setName("沙和尚");
        MyThreadTicket threadTicket3 = new MyThreadTicket();
        threadTicket3.setName("孫猴子");

        System.out.println("---搶票開始---");
        threadTicket1.start();
        threadTicket2.start();
        threadTicket3.start();

    }
}

運行結果

---搶票開始---
豬八戒買到第1張票,剩餘99張票
孫猴子買到第1張票,剩餘99張票
沙和尚買到第1張票,剩餘99張票
孫猴子買到第2張票,剩餘98張票
豬八戒買到第2張票,剩餘98張票
沙和尚買到第2張票,剩餘98張票
孫猴子買到第3張票,剩餘97張票
沙和尚買到第3張票,剩餘97張票
豬八戒買到第3張票,剩餘97張票
豬八戒買到第4張票,剩餘96張票
沙和尚買到第4張票,剩餘96張票
孫猴子買到第4張票,剩餘96張票
孫猴子買到第5張票,剩餘95張票
......
孫猴子買到第99張票,剩餘1張票
豬八戒買到第99張票,剩餘1張票
沙和尚買到第99張票,剩餘1張票
孫猴子買到第100張票,剩餘0張票
豬八戒買到第100張票,剩餘0張票
沙和尚買到第100張票,剩餘0張票

出現的問題

每個人都買了100張票,沒有共用數據;

1.2 通過實現Runnable介面買票

實現Runnable介面案例

/*
    模擬網路購票,實現Runnable方法
 */
public class MyRunnableTicket0 implements Runnable{
    //總票數
    private int remainSite = 100;

    //搶到的座位號
    private int buySite = 0;

    @Override
    public void run() {
        //模擬迴圈搶票
        while(true){
            //判斷餘票是否充足,如果不足,結束
            if (remainSite <= 0) {
                break;
            }

            //更改強股票數據
            buySite++;
            remainSite--;

            //模擬網路延遲
            try {
                TimeUnit.MILLISECONDS.sleep(20);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() + "買到第" + buySite + "張票,剩餘" + remainSite + "張票");
        }

    }

    public static void main(String[] args) {
        //創建三個子線程
        MyRunnableTicket0 runnableTicket = new MyRunnableTicket0();
        Thread thread1 = new Thread(runnableTicket,"哪吒");
        Thread thread2 = new Thread(runnableTicket,"金吒");
        Thread thread3 = new Thread(runnableTicket,"木吒");

        thread1.start();
        thread2.start();
        thread3.start();
    }
}

運行結果

木吒買到第96張票,剩餘4張票
哪吒買到第96張票,剩餘4張票
金吒買到第96張票,剩餘4張票
木吒買到第99張票,剩餘1張票
哪吒買到第99張票,剩餘1張票
金吒買到第99張票,剩餘1張票
木吒買到第100張票,剩餘0張票

出現的問題

共用了數據,但是出現了漏票,和幾個人買同一張票的情況;

2、解決方法

通過synchronized同步鎖來進行同步,使同一時間只有一個人在買票

2.1 同步代碼塊

同步代碼塊案例

/*
    模擬網路購票,實現Runnable方法
    同步代碼塊方法
 */
public class MyRunnableTicket implements Runnable{
    //總票數
    private int remainSite = 100;

    //搶到的座位號
    private int buySite = 0;
    //同步代碼塊
    @Override
    public void run() {
        //模擬迴圈搶票
        while(true){
            //同步代碼快
            synchronized (this) {
                //判斷餘票是否充足,如果不足,結束
                if (remainSite <= 0) {
                    break;
                }

                //更改強股票數據
                buySite++;
                remainSite--;

                //模擬網路延遲
                try {
                    TimeUnit.MILLISECONDS.sleep(20);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

                System.out.println(Thread.currentThread().getName() + "買到第" + buySite + "張票,剩餘" + remainSite + "張票");
            }
        }
    }

    public static void main(String[] args) {
        //創建三個子線程
        MyRunnableTicket runnableTicket = new MyRunnableTicket();
        Thread thread1 = new Thread(runnableTicket,"哪吒");
        Thread thread2 = new Thread(runnableTicket,"金吒");
        Thread thread3 = new Thread(runnableTicket,"木吒");

        thread1.start();
        thread2.start();
        thread3.start();
    }
}

運行結果

哪吒買到第1張票,剩餘99張票
哪吒買到第2張票,剩餘98張票
哪吒買到第3張票,剩餘97張票
哪吒買到第4張票,剩餘96張票
哪吒買到第5張票,剩餘95張票
......
金吒買到第96張票,剩餘4張票
金吒買到第97張票,剩餘3張票
金吒買到第98張票,剩餘2張票
金吒買到第99張票,剩餘1張票
金吒買到第100張票,剩餘0張票

可以正常買票,問題解決;

2.2 同步方法

同步方法案例

/*
    模擬網路購票,實現Runnable方法
    同步方法
 */
public class MyRunnableTicket implements Runnable{
    //總票數
    private int remainSite = 100;

    //搶到的座位號
    private int buySite = 0;

    @Override
    public void run() {
        //模擬迴圈搶票
        while(remainSite > 0){

            //調用同步購買方法
            buyTicket();

            //模擬網路延遲
            try {
                TimeUnit.MILLISECONDS.sleep(20);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

        }
    }

    /*
        同步方法
        增加同步鎖,限制多線程場景下,只允許一個線程執行當前方法,確保票數修改正確
     */
    public synchronized void buyTicket(){
        //判斷餘票是否充足,如果不足,結束
        if(remainSite <= 0){
            return;
        }

        //更改強股票數據
        buySite++;
        remainSite--;

        System.out.println(Thread.currentThread().getName()+"買到第"+buySite+"張票,剩餘"+remainSite+"張票");
    }

運行結果

哪吒買到第1張票,剩餘99張票
哪吒買到第2張票,剩餘98張票
哪吒買到第3張票,剩餘97張票
哪吒買到第4張票,剩餘96張票
哪吒買到第5張票,剩餘95張票
......
金吒買到第96張票,剩餘4張票
金吒買到第97張票,剩餘3張票
金吒買到第98張票,剩餘2張票
金吒買到第99張票,剩餘1張票

可以正常買票,問題解決;


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • #數據類型 P23 ##(強類型語言:要求變數的使用要嚴格符合規定,所有變數都必須先定義後使用。) ##整數類型: ###byte占1個位元組 範圍:(-128127) ###short占2個位元組 範圍:(-3276832767) ###int占4個位元組 範圍:(-214748364821474836 ...
  • 一個美女面試官坐到我的對面,發光logo的MacBook也擋不住她那圓潤可愛的臉龐。 程式媛本就稀有,美女面試官更是難尋。具體長什麼樣呢?就像下麵這樣: 這麼溫柔可愛的面試官,應該不會為難我吧。嗯,應該是的,畢竟我這麼帥氣,面試可能就是走個過場。美女面試官是不是單身?畢竟程式員都不善交流,因為我也是 ...
  • 引言:今天閱讀前人源碼,看見一個提取文件名字的功能,用了string的函數折騰了一大堆,結果一查MsDoc,微軟原來早都提供了5個用於提取文件名稱的函數。 個人技術博客(文章整理+源碼): https://zobolblog.github.io/LearnWinAPI/ 最終效果: 1.CFileD ...
  • 點擊藍色“程式員黃小斜”關註我喲 加個“星標”,每天和你一起多進步一點點! 今天給大家分享一篇有意思的爽文,但也是根據多年之前一個真實報道改編而來的。 本文字數較多,建議先收藏,上下班路上、帶薪上廁所、渾水摸魚時再慢慢看~ 來源: https://www.zhihu.com/question/483 ...
  • Spring5——JdbcTemplate筆記 概念 template,翻譯過來是模板的意思,顧名思義,JdbcTemplate就是一個JDBC的模板,它對JDBC進行了封裝,可以很方便地實現對資料庫的CRUD(增、刪、改、查)的操作。 JdbcTemplate準備工作 引入相關的依賴 druid- ...
  • 給大家推薦八個非常實用的Python案例,希望大家看過後能夠有所收穫! 1、合併兩個字典 Python3.5之後,合併字典變得容易起來,我們可以通過**符號解壓字典,並將多個字典傳入{}中,實現合併。 def Merge(dict1,dict2): res = {**dict1,**dict2} r ...
  • 1、Collections sort(List list) 自然升序排序 reverse(List<?> list) 集合反轉 binarySearch(List<? extends Comparable<? super T>> list, T key) 二分查找(要求集合有序) addAll(Co ...
  • 前言 利用selenium在做自動化測試的時候,經常會用到數據來做批量測試,常用的方式有讀取txt文件,xml文件,csv文件以及excel文 件幾種。 使用 excel 來做數據管理時,需要利用 xlrd、xlwt 開源包來讀寫 excel。 1、安裝xlrd、xlwt pip install x ...
一周排行
    -Advertisement-
    Play Games
  • 1.部署歷史 猿友們好,作為初來實習的我,已經遭受社會的“毒打”,所以請容許我在下麵環節適當吐槽,3Q! 傳統部署 ​ 回顧以往在伺服器部署webapi項目(非獨立發佈),dotnet環境、守護進程兩個逃都逃不掉,正常情況下還得來個nginx代理。不僅僅這仨,可能牽扯到yum或npm。node等都要 ...
  • 隨著技術的進步,跨平臺開發已經成為了標配,在此大背景下,ASP.NET Core也應運而生。本文主要基於ASP.NET Core+Element+Sql Server開發一個校園圖書管理系統為例,簡述基於MVC三層架構開發的常見知識點,前一篇文章,已經簡單介紹瞭如何搭建開發框架,和登錄功能實現,本篇... ...
  • 這道題只要會自定義cmp恰當地進行排序,其他部分沒有什麼大問題。 上代碼: 1 #include<bits/stdc++.h> 2 using namespace std; 3 int n,s,h1,h2,cnt; 4 struct apple{ 5 int height,ns;//height為蘋 ...
  • 這篇文章主要描述RPC的路由策略,包括為什麼需要請求隔離,為什麼不在註冊中心中實現請求隔離以及不同粒度的路由策略。 ...
  • 簡介: 中介者模式,屬於行為型的設計模式。用一個中介對象來封裝一系列的對象交互。中介者是各對象不需要顯式地相互引用,從而使其耦合鬆散,而且可以獨立地改變他們之間的交互。 適用場景: 如果平行對象間的依賴複雜,可以使用中介者解耦。 優點: 符合迪米特法則,減少成員間的依賴。 缺點: 不適用於系統出現對 ...
  • 【前置內容】Spring 學習筆記全系列傳送門: Spring學習筆記 - 第一章 - IoC(控制反轉)、IoC容器、Bean的實例化與生命周期、DI(依賴註入) Spring學習筆記 - 第二章 - 註解開發、配置管理第三方Bean、註解管理第三方Bean、Spring 整合 MyBatis 和 ...
  • 簡介: 享元模式,屬於結構型的設計模式。運用共用技術有效地支持大量細粒度的對象。 適用場景: 具有相同抽象但是細節不同的場景中。 優點: 把公共的部分分離為抽象,細節依賴於抽象,符合依賴倒轉原則。 缺點: 增加複雜性。 代碼: //用戶類 class User { private $name; fu ...
  • 這次設計一個通用的多位元組SPI介面模塊,特點如下: 可以設置為1-128位元組的SPI通信模塊 可以修改CPOL、CPHA來進行不同的通信模式 可以設置輸出的時鐘 狀態轉移圖和思路與多位元組串口發送模塊一樣,這裡就不給出了,具體可看該隨筆。 一、模塊代碼 1、需要的模塊 通用8位SPI介面模塊 `tim ...
  • AOP-03 7.AOP-切入表達式 7.1切入表達式的具體使用 1.切入表達式的作用: 通過表達式的方式定義一個或多個具體的連接點。 2.語法細節: (1)切入表達式的語法格式: execution([許可權修飾符] [返回值類型] [簡單類名/全類名] [方法名]([參數列表]) 若目標類、介面與 ...
  • 測試一、虛繼承與繼承的區別 1.1 單個繼承,不帶虛函數 1>class B size(8): 1> + 1> 0 | + (base class A) 1> 0 | | _ia //4B 1> | + 1> 4 | _ib //4B 有兩個int類型數據成員,占8B,基類邏輯存在前面 1.2、單個 ...