Java多線程基礎（二）

来源:https://www.cnblogs.com/loober/archive/2019/01/09/10235234.html
-Advertisement-
Play Games

1.多線程數據安全 線程同步：多個線程需要訪問同一資源時，需要以某種順序來確定該資源某一時刻只能被一個線程使用。 2.同步代碼塊實現同步（部分代碼的訪問，我們希望它同步） package com.test; public class ThreadDemo1 { public static void ...


1.多線程數據安全

　　線程同步：多個線程需要訪問同一資源時，需要以某種順序來確定該資源某一時刻只能被一個線程使用。從而，解決併發操作可能帶來的異常。

2.同步代碼塊實現同步（部分代碼的訪問，我們希望它同步）

synchronized(lock){
       //同步代碼塊
}

　　其中lock就是同步監視器，它的含義是：線程開始執行同步代碼塊之前，必須先獲得對同步監視器的鎖定。任何時刻只能有一個線程可以獲得對同步監視器的鎖定，當同步代碼塊執行完成後，該線程會釋放對該同步監視器的鎖定。雖然java程式允許使用任何對象作為同步監視器，但是同步監視器的目的就是為了阻止兩個線程對同一個共用資源進行併發訪問，因此通常使用可能被併發訪問的共用資源充當同步監視器。

　　下麵的實例可方便理解：

package com.test;

public class ThreadDemo1 {

    public static void main(String[] args) {
        // TODO Auto-generated method stub
        //創建共用資源對象
        TicketRes ticketRes=new TicketRes();
        //創建線程對象
        Thread w1=new Thread(ticketRes,"視窗1");
        Thread w2=new Thread(ticketRes,"視窗2");
        Thread w3=new Thread(ticketRes,"視窗3");
        w1.start();
        w2.start();
        w3.start();
    }
}
//共用資源類
class TicketRes implements Runnable{
    private int ticket=100;
    private Object lock=new Object();//鎖
    
    @Override
    public void run() {
        // TODO Auto-generated method stub
        while(true) {
            synchronized (lock) {
                if(ticket>=1) {
                    try {
                        Thread.sleep(10);
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread().getName()+"賣第"+ticket+"張票");
                    ticket--;
                }else {
                    break;
                }
            }
        }
    }
}
View Code

3.同步方法實現同步（強調功能，方法的訪問是同步的）

　　同步方法就是使用synchronized關鍵字修飾某個方法，用synchronized修飾的方法就是同步方法。這個同步方法(非static方法)無須顯式指定同步監視器，同步方法的同步監視器是this，也就是調用該方法的對象，通過同步方法可以非常方便的實現線程安全的類。

　　下麵的實例可方便理解：

package com.test;

public class ThreadDemo2 {

    public static void main(String[] args) {
        // TODO Auto-generated method stub
        //創建共用資源對象
        TicketRes1 ticketRes=new TicketRes1();
        //創建線程對象
        Thread w1=new Thread(ticketRes,"視窗1");
        Thread w2=new Thread(ticketRes,"視窗2");
        Thread w3=new Thread(ticketRes,"視窗3");
        w1.start();
        w2.start();
        w3.start();
    }
}
//共用資源類
class TicketRes1 implements Runnable{
    private static int ticket=100;
    private Object lock=new Object();//鎖
    
    @Override
    public void run() {
        // TODO Auto-generated method stub
        while(true) {
            if(!TicketRes1.saleTicket()) {
                break;
            }
        }
    }
    public synchronized static boolean saleTicket() {
        if(ticket>=1) {
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName()+"賣第"+ticket+"張票");
            ticket--;
            return true;
        }else {
            return false;
        }
    }
}
View Code

4.鎖的概念以及死鎖問題

　　多線程在運行的時候可能會遇到這樣的問題，多個線程要用到同一個資源，那可能會出現錯亂，比如線程要改動資源里的數據，那麼多個線程同時改就亂了套了。就像公共廁所，必須要一個一個接著上，不能兩個人或者多個人同時上。那麼鎖這個概念就是像上廁所的門，一個人在上廁所，鎖上了門，那下一個人就不能進去了。同樣的，如果我們想讓某一個程式或者某一個變數只能同時被一個線程運行，就得給程式上鎖。所以上了鎖，就能保證線程有秩序地運行。

　　當兩個線程相互等待對方釋放同步監視器時就會發生死鎖，Java虛擬機沒有檢測，也沒有採取措施來處理死鎖情況，所以多線程編程時應該採取措施避免死鎖出現。一旦出現死鎖，程式既不會發生任何異常，也不會給出任何提示，只是所有線程都處於阻塞狀態，無法繼續。

　　接下來看一個死鎖的Java實例（是不是停不下來了，就相當於迴圈語句的死迴圈）　　

　　 
package com.test;

public class DeadLock {

    public static void main(String[] args) {
        // TODO Auto-generated method stub
        DeadLockThread he=new DeadLockThread(true,"小明");//他
        DeadLockThread she=new DeadLockThread(false,"小華 ");//她
        he.start();
        she.start();    
    }
}
//線程
class DeadLockThread extends Thread{
    boolean flag=false;
    public DeadLockThread() {
    
    }
    protected DeadLockThread(boolean flag,String name) {
        super(name);
        this.flag=flag;
    }
    public void run() {
        while(true) {
            if(flag) {
                synchronized (Lock.locka) {//他
                    System.out.println(Thread.currentThread().getName()+"搶到了locka");
                }
                synchronized (Lock.lockb) {
                    System.out.println(Thread.currentThread().getName()+"搶到了lockb");
                    System.out.println(Thread.currentThread().getName()+"可以上廁所了");
                    
                }
            }else {
                synchronized (Lock.lockb) {//她
                    System.out.println(Thread.currentThread().getName()+"搶到了lockb");
                }
                synchronized (Lock.locka) {
                    System.out.println(Thread.currentThread().getName()+"搶到了locka");
                    System.out.println(Thread.currentThread().getName()+"可以上廁所了");
                }
            }
        }
    }
}
//創建鎖對象
class Lock{
    public static Object locka=new Object();
    public static Object lockb=new Object(); 
}
View Code

5.線程終止

　　1.使用標誌，使run()方法正常執行完畢

　　 
package com.test;

import java.util.Scanner;

public class Demo1 {

    public static void main(String[] args) {
        // TODO Auto-generated method stub
        FlagStop flagStop=new FlagStop("線程1");
        flagStop.start();
        Scanner input=new Scanner(System.in);
        System.out.println("輸入任意字元結束主線程");
        input.next();
        flagStop.flag=false;//主線程修改其他線程的變數
        System.out.println("主線程結束");
    }

}
class FlagStop extends Thread{
    //定義標誌 volatile:易揮發的、不穩定的，使用volatile修飾後，獲取變數不會從緩存中取，從記憶體中取。
    volatile boolean flag=true;
    public FlagStop() {
        // TODO Auto-generated constructor stub
    }

    public FlagStop(String name) {
        super(name);
        // TODO Auto-generated constructor stub
    }

    @Override
    public void run() {
        // TODO Auto-generated method stub
        System.out.println(Thread.currentThread().getName()+"開始執行了");
        while(flag) {
            
        }
        System.out.println(Thread.currentThread().getName()+"執行完畢");
    }
}
View Code

　　2.使用stop方法強制終止線程

　　 
package com.test;

import java.util.Scanner;

public class Demo2 {

    public static void main(String[] args) {
        // TODO Auto-generated method stub
        WordStop wordStop=new WordStop("線程1");
        wordStop.start();
        Scanner input=new Scanner(System.in);
        System.out.println("輸入任意字元結束主線程");
        input.next();
        wordStop.stop();
        wordStop.flag=false;//主線程修改其他線程的變數
        System.out.println("主線程結束");
    }

}
class WordStop extends Thread{
    //定義標誌 volatile:易揮發的、不穩定的，使用volatile修飾後，獲取變數不會從緩存中取，從記憶體中取。
    volatile boolean flag=true;
    public WordStop() {
        // TODO Auto-generated constructor stub
    }

    public WordStop(String name) {
        super(name);
        // TODO Auto-generated constructor stub
    }

    @Override
    public void run() {
        // TODO Auto-generated method stub
        System.out.println(Thread.currentThread().getName()+"開始執行了");
        while(flag) {
            
        }
        System.out.println(Thread.currentThread().getName()+"執行完畢");
    }
}
View Code

　　3.使用interrupt方法中斷線程

　　 
package com.test;

import java.io.IOException;

public class Demo3 {

    public static void main(String[] args) throws IOException, InterruptedException {
        // TODO Auto-generated method stub
        InterruptStop interruptStop=new InterruptStop();
        interruptStop.start();
        System.out.println("在10秒之內輸入任意符號結束");
        System.in.read();
        interruptStop.interrupt();//打斷正在休眠的線程
        interruptStop.join();
        System.out.println("主線程結束...");
    }
}
class InterruptStop extends Thread{
    @Override
    public void run() {
        try {
            Thread.sleep(10000);//拋出一個異常InterruptedException
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
//            e.printStackTrace();
            System.out.println("執行了catch");
        }
        System.out.println("子線程執行完畢");
    }
}
View Code

6.線程間通信

　　1.wait:掛起當前線程，釋放共用資源鎖

　　2.notify:在所有的wait線程當中隨機選擇一條喚醒

　　3.notifyAll:喚醒全部wait線程


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

-Advertisement-
Play Games
更多相關文章
  • Java 控制類的引用類型，合理使用記憶體
    Java提供了 java.lang.ref包,該包下的類均與垃圾回收機制相關 先介紹Java對象的集中引用類型 1.強引用 強引用是最常見的,創建對象就是強引用,如 String a = new String("1"); 無論系統記憶體是否緊張,只要該對象還存在強引用就不會被垃圾回收機制回收 2.軟引 ...
  • 多線程系列之 線程安全
    序言：提到線程安全，可能大家首先想到的是確保介面對共用變數的操作要具備 原子性。實際上，在多線程編程中我們需要同時關註可見性，順序性和原子性。本篇文章將從這三個問題出發，結合實例詳解volatile如何保u證可見性及一定程式上保證順序性，同時例講synchronized如何同時保證可見性和原子性，最 ...
  • Python 推薦書單
    以下書籍都是本人看過的書籍，僅做參考。 個人推薦一本一本看，不要跨級，步子大了容易扯著dan。 《電腦科學導論》 本人靠這本書入門電腦，也許談不上入門 《網路是怎樣連接的》《電腦組成原理》《電腦操作系統》 這四本不用多說，電腦基礎中的基礎，不說要全部記住，至少要一目十行看完這三大本，對計算 ...
  • Perl一行式：選擇行輸出、刪除、追加、插入
    perl一行式程式系列文章 ： "Perl一行式" 對於Perl的一行式perl程式來說，選擇要輸出的、要刪除的、要插入/追加的行是非常容易的事情，因為print/say決定行是否輸出/插入/追加/刪除。雖然簡單，但對於廣泛應用在sed的示例還是可以拿到這裡來討論一番。 因為輸出/刪除/插入/追加行 ...
  • selenium-獲取一組數組進行操作
    selenium-獲取一組數組進行操作 以 縱橫中文網 中獲取24小時暢銷榜的書單為例 此文僅做 selenium 在自動化測試中怎麼獲取一組數據進行說明，不做網路爬蟲解釋 當然，使用爬蟲得到本文的結果會簡單快捷的多 區別 selenium 中的 elements 與 element 例如：list ...
  • Django組件之cookie與session
    一、引子 http協議是無狀態的，就是它不會記錄請求和響應的任何信息，比如你訪問一個伺服器的一個網頁時，先要你登錄一下，然後進入網頁，但當你要進入這個伺服器的另一個網頁時，它照常不會知道剛纔你已經登錄過了，又要讓你登錄一下，就是一個bug。但是，你說你每次上網的時候，只需要登錄一下就行了，並沒有我說 ...
  • 初學python來進行odoo12版本開發
    這是我的第一篇博客。請多多指教！ 首先要下載odoo-12的源代碼 官方下載路徑： https://github.com/odoo/odoo/archive/12.0.zip 隨便新建一個文件夾，我放到D盤裡名為 GZZX（工作中心） 打開pycharm開發工具將odoo-12源代碼導入，然後再Fi ...
  • 分支程式設計練習（初學者）
    例：輸入三個整數，輸出最大值和最小值。 #include<stdio.h>int main(){ int a,b,c,max,min; printf("input three numbers:"); scanf("%d%d%d",&a,&b,&c); if(a>b) {max=a;min=b;} e ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類