Java多線程（三）

来源:https://www.cnblogs.com/xiaozhao01/archive/2022/08/05/16555777.html
-Advertisement-
Play Games

Java多線程（三） 五、線程的通信 5.1 wait() 與 notify() 和 notifyAll() 介紹： wait()：令當前線程掛起並放棄CPU、同步資源並等待，使別的線程可訪問並修改共用資源，而當前線程排隊等候其他線程調用notify() 或 notifyAll() 方法喚醒，喚醒後 ...


Java多線程（三）

目錄

五、線程的通信

5.1 wait() 與 notify() 和 notifyAll() 介紹：

  1. wait()：令當前線程掛起並放棄CPU、同步資源並等待，使別的線程可訪問並修改共用資源，而當前線程排隊等候其他線程調用notify() 或 notifyAll() 方法喚醒，喚醒後等待重新獲得對監視器的所有權後才能繼續執行。
  2. notify()：喚醒正在排隊等待同步資源的線程中優先順序最高者結束等待。
  3. notifyAll ()：喚醒正在排隊等待資源的所有線程結束等待。

  • 這三個方法只有在 synchronized 方法 或 synchronized 代碼塊中才能使用，否則會報 java.lang.IllegalMonitorStateException異常。

  • 因為這三個方法必須有鎖對象調用，而任意對象都可以作為 synchronized 的同步鎖， 因此這三個方法只能在Object類中聲明。

5.2 wait() 的使用：

  1. 在當前線程中調用方法： 對象名.wait() 。
  2. 使當前線程進入等待（某對象）狀態 ，直到另一線程對該對象發出 notify (或notifyAll) 為止。
  3. 調用方法的必要條件：當前線程必須具有對該對象的監控權（加鎖）。
  4. 調用此方法後，當前線程將釋放對象監控權 ，然後進入等待。
  5. 在當前線程被 notify 後，要重新獲得監控權，然後從斷點處繼續代碼的執行。

5.3 notify() / notifyAll() 的使用

  1. 在當前線程中調用方法： 對象名.notify()。
  2. 功能：喚醒等待該對象監控權的一個/所有線程。
  3. 調用方法的必要條件：當前線程必須具有對該對象的監控權（加鎖）。

5.4 經典例題：生產者/消費者問題

題目描述：

生產者（Productor）將產品交給店員（Clerk），而消費者（Customer）從店員處取走產品，店員一次只能持有固定數量的產品（比如:20），如果生產者試圖生產更多的產品，店員會叫生產者停一下，如果店中有空位放產品了再通知生產者繼續生產；如果店中沒有產品了，店員會告訴消費者等一下，如 果店中有產品了再通知消費者來取走產品。

class Clerk{

    private int productCount = 0;
    //生產產品
    public synchronized void produceProduct() {

        if(productCount < 20){
            productCount++;
            System.out.println(Thread.currentThread().getName() + ":開始生產第" + productCount + "個產品");
            
            notify();

        }else{
            //等待
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    //消費產品
    public synchronized void consumeProduct() {
        if(productCount > 0){
            System.out.println(Thread.currentThread().getName() + ":開始消費第" + productCount + "個產品");
            productCount--;

            notify();
        }else{
            //等待
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

class Producer extends Thread{//生產者

    private Clerk clerk;

    public Producer(Clerk clerk) {
        this.clerk = clerk;
    }

    @Override
    public void run() {
        System.out.println(getName() + ":開始生產產品.....");

        while(true){
            
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            clerk.produceProduct();
        }
    }
}

class Consumer extends Thread{//消費者
    private Clerk clerk;

    public Consumer(Clerk clerk) {
        this.clerk = clerk;
    }

    @Override
    public void run() {
        System.out.println(getName() + ":開始消費產品.....");

        while(true){

            try {
                Thread.sleep(20);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            clerk.consumeProduct();
        }
    }
}

public class ProductTest {

    public static void main(String[] args) {
        Clerk clerk = new Clerk();

        Producer p1 = new Producer(clerk);
        p1.setName("生產者1");

        Consumer c1 = new Consumer(clerk);
        c1.setName("消費者1");
        Consumer c2 = new Consumer(clerk);
        c2.setName("消費者2");

        p1.start();
        c1.start();
        c2.start();
    }
}

六、JDK5.0新增多線程創建方式

6.1 多線程的創建方式之三：實現Callable介面

  1. 創建一個實現 Callable 的實現類
  2. 實現call方法，將此線程需要執行的操作聲明在call() 中。
  3. 創建 Callable 介面實現類的對象。
  4. 將此 Callable 介面實現類的對象作為傳遞到 FutureTask 構造器中，創建 FutureTask 的對象。
  5. 將 FutureTask 的對象作為參數傳遞到 Thread 類的構造器中，創建 Thread 對象，並調用 start() 。
  6. 獲取 Callable 中 call 方法的返回值。（可選）
//1.創建一個實現Callable的實現類
class NumThread implements Callable{
    //2.實現call方法，將此線程需要執行的操作聲明在call()中
    @Override
    public Object call() throws Exception {
        int sum = 0;
        for (int i = 1; i <= 100; i++) {
            if(i % 2 == 0){
                System.out.println(i);
                sum += i;
            }
        }
        return sum;
    }
}

public class ThreadNew {
    public static void main(String[] args) {
        
        //3.創建Callable介面實現類的對象
        NumThread numThread = new NumThread();
        //4.將此Callable介面實現類的對象作為傳遞到FutureTask構造器中，創建FutureTask的對象
        FutureTask futureTask = new FutureTask(numThread);
        //5.將FutureTask的對象作為參數傳遞到Thread類的構造器中，創建Thread對象，並調用start()
        new Thread(futureTask).start();

        try {
            //6.獲取Callable中call方法的返回值
            //get()返回值即為FutureTask構造器參數Callable實現類重寫的call()的返回值。
            Object sum = futureTask.get();
            System.out.println("總和為：" + sum);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }
}

  • 與使用 Runnable 相比， Callable功能更強大些：

    1. 相比run()方法，可以有返回值。
    2. 方法可以拋出異常。
    3. 支持泛型的返回值。
    4. 需要藉助 FutureTask 類，比如獲取返回結果。

  • Future 介面：

    1. 可以對具體Runnable、Callable任務的執行結果進行取消、查詢是否完成、獲取結果等。
    2. FutrueTask 是 Futrue 介面的唯一的實現類。
    3. FutureTask 同時實現了Runnable, Future介面。它既可以作為 Runnable 被線程執行，又可以作為 Future 得到 Callable 的返回值。

6.2 多線程的創建方式之四：使用線程池

  1. 線程池的引入：

    經常創建和銷毀、使用量特別大的資源，比如併發情況下的線程， 對性能影響很大。

  2. 線程池的思路：

    提前創建好多個線程，放入線程池中，使用時直接獲取，使用完放回池中。可以避免頻繁創建銷毀、實現重覆利用。

  3. 使用線程池的好處：

    • 提高響應速度（減少了創建新線程的時間）

    • 降低資源消耗（重覆利用線程池中線程，不需要每次都創建）

    • 便於線程管理

      corePoolSize：核心池的大小

      maximumPoolSize：最大線程數

      keepAliveTime：線程沒有任務時最多保持多長時間後會終止

  4. 線程池的使用：

（1）提供指定線程數量的線程池。

（2）執行指定的線程的操作，需要提供實現 Runnable 介面或 Callable 介面實現類的對象。

（3）關閉連接池。

class NumberThread implements Runnable{

    @Override
    public void run() {
        for(int i = 0;i <= 100;i++){
            if(i % 2 == 0){
                System.out.println(Thread.currentThread().getName() + ": " + i);
            }
        }
    }
}

class NumberThread1 implements Runnable{

    @Override
    public void run() {
        for(int i = 0;i <= 100;i++){
            if(i % 2 != 0){
                System.out.println(Thread.currentThread().getName() + ": " + i);
            }
        }
    }
}

public class ThreadPool {

    public static void main(String[] args) {
        //1. 提供指定線程數量的線程池
        ExecutorService service = Executors.newFixedThreadPool(10);
      
        //2.執行指定的線程的操作。需要提供實現Runnable介面或Callable介面實現類的對象
        service.execute(new NumberThread());//適合適用於Runnable
        service.execute(new NumberThread1());//適合適用於Runnable
//        service.submit(Callable callable);//適合使用於Callable
        
        //3.關閉連接池
        service.shutdown();
    }
}
  1. 線程池相關API
  • JDK 5.0 起提供了線程池相關API：ExecutorService 和 Executors 。
  • ExecutorService：真正的線程池介面。常見子類 ThreadPoolExecutor。
//	執行任務/命令，沒有返回值，一般用來執行 Runnable
	void execute(Runnable command)
        
//	執行任務，有返回值，一般又來執行 Callable
    Future submit(Callable task)

//	關閉連接池
    void shutdown()
  • Executors：工具類、線程池的工廠類，用於創建並返回不同類型的線程池。
//	創建一個可根據需要創建新線程的線程池
	Executors.newCachedThreadPool()
        
//	創建一個可重用固定線程數的線程池        
	Executors.newFixedThreadPool(n)
        
//	創建一個只有一個線程的線程池          
    Executors.newSingleThreadExecutor() 
        
//	創建一個線程池，它可安排在給定延遲後運行命令或者定期地執行。 
	Executors.newScheduledThreadPool(n)

  1. 線程池的屬性設置

    • ExecutorService 是一個介面，裡面並沒有設置線程池屬性的方法，故不能用該介面的對象來對線程池進行屬性設置。

    • 設置線程池屬性需要通過創建 ExecutorService 介面的實現類 ThreadPoolExecutor 的對象，調用該實現類的方法進行設置。

        ThreadPoolExecutor service1 = (ThreadPoolExecutor) service;
        //設置線程池的屬性
        service1.setCorePoolSize(15);
        service1.setKeepAliveTime();

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

-Advertisement-
Play Games
更多相關文章
  • 記錄--Three.js入門教程——教不會算我輸
    這裡給大家分享我在網上總結出來的一些知識，希望對大家有所幫助 在javascript中使用Three.js設計並且實現3D場景是一個很有意思的事情，因為在瀏覽器中就能夠渲染出3D場景，非常簡單和輕便。接下來就總結以下我學習Three.js過程中的心得。 1 建立基本場景 在Three.js中有三要素 ...
  • Vue腳手架的開始，項目目錄，綁定文本、屬性、事件
    安裝 首先需要安裝好NPM，然後使用下列的命令一次進行 npm install -g @vue/cli //安裝腳手架 vue create xx //創建Vue項目,xx為要創建的項目名 創建項目後，使用 cd 進入目錄 npm run serve //啟動項目 目錄 Pubulic：靜態文件 s ...
  • （前端）「備忘錄」設計模式在項目開發中的應用
    1. 事件起因 之前做一個駕照考題的項目，有一個這樣的問題，每當我選好了科目和駕照類型後（如圖1），點擊開始考試就會跳到考試頁面（Test.tsx），並且在Test組件中對我架設的中間層發起請求獲取數據（如圖2）。 如果用戶手滑的話不小心點到了左上角的返回，或者狠狠地把屏幕往右滑動一下的話，都會返回 ...
  • （前端）「中介者」設計模式在項目開發中的應用
    1. 事件起因 事情是這樣的，我之前在做一個仿網易雲的項目，想實現一個功能，就是點擊歌曲列表組件（MusicList）中每一個item時，底部播放欄（FooterMusic）就能夠獲取我所點擊的這首歌曲的所有信息（如圖1到圖2），但是底部播放欄是直接放在外殼組件App.vue中固定定位的，歌曲列表組 ...
  • 結合“xPlus”探討軟體架構的創新與變革
    引言 當今社會對軟體需求在相當長的時間里將保持旺盛，而軟體開發周期長、個性化難、順應需求變更不變，如何可以才能將軟體開發定製變得簡單方便快捷呢？ 1. 軟體開發設計現狀 目前軟體的開發設計都是定向開發，即根據項目需求將相關的數據關係、業務邏輯、功能模塊及介面插件等揉合在一起並與人機交互整體開發（若涉 ...
  • 單元測試、反射、註解、動態代理
    單元測試JUnit 單元測試的目的是針對方法進行測試， **JUnit的兩個要點：**①必須是公開的，無參數，無返回值的方法 ②測試方法必須使用@Test註解標記 public class JUnitTest { @Test public void Testusername() { way way ...
  • IOS OpenGL ES GPUImage 圖像疊加 GPUImageOverlayBlendFilter
    目錄 一.簡介 二.效果演示 三.源碼下載 四.猜你喜歡 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 基礎 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 轉場 零基礎 O ...
  • Java多線程併發編程
    多線程併發 在多核CPU中，利用多線程併發編程，可以更加充分地利用每個核的資源 在Java中，一個應用程式對應著一個JVM實例（也有地方稱為JVM進程），如果程式沒有主動創建線程，則只會創建一個主線程。但這不代表JVM中只有一個線程，JVM實例在創建的時候，同時會創建很多其他的線程（比如垃圾收集器線 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類