Java多線程打輔助的三個小伙子

来源:https://www.cnblogs.com/Java3y/archive/2018/07/27/9375669.html
-Advertisement-
Play Games

前言 之前學多線程的時候沒有學習線程的同步工具類(輔助類)。ps:當時覺得暫時用不上，認為是挺高深的知識點就沒去管了.. 在前幾天，朋友發了一篇比較好的Semaphore文章過來，然後在瀏覽博客的時候又發現面試還會考，那還是挺重要的知識點。於是花了點時間去瞭解一下。 Java為我們提供了 三個同步工 ...


前言

之前學多線程的時候沒有學習線程的同步工具類(輔助類)。ps:當時覺得暫時用不上，認為是挺高深的知識點就沒去管了..

在前幾天，朋友發了一篇比較好的Semaphore文章過來，然後在瀏覽博客的時候又發現面試還會考，那還是挺重要的知識點。於是花了點時間去瞭解一下。

Java為我們提供了三個同步工具類：

  • CountDownLatch(閉鎖)
  • CyclicBarrier(柵欄)
  • Semaphore(信號量)

這幾個工具類其實說白了就是為了能夠更好控制線程之間的通訊問題~

一、CountDownLatch

1.1CountDownLatch簡介

  • A synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads completes.

簡單來說：CountDownLatch是一個同步的輔助類，允許一個或多個線程一直等待，直到其它線程完成它們的操作。

它常用的API其實就兩個:await()和countDown()

使用說明：

  • count初始化CountDownLatch，然後需要等待的線程調用await方法。await方法會一直受阻塞直到count=0。而其它線程完成自己的操作後，調用countDown()使計數器count減1。當count減到0時，所有在等待的線程均會被釋放
  • 說白了就是通過count變數來控制等待，如果count值為0了(其他線程的任務都完成了)，那就可以繼續執行。

1.2CountDownLatch例子

例子：3y現在去做實習生了，其他的員工還沒下班，3y不好意思先走，等其他的員工都走光了，3y再走。


import java.util.concurrent.CountDownLatch;

public class Test {

    public static void main(String[] args) {

        final CountDownLatch countDownLatch = new CountDownLatch(5);

        System.out.println("現在6點下班了.....");

        // 3y線程啟動
        new Thread(new Runnable() {
            @Override
            public void run() {
           
                try {
                    // 這裡調用的是await()不是wait()
                    countDownLatch.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("...其他的5個員工走光了，3y終於可以走了");
            }
        }).start();

        // 其他員工線程啟動
        for (int i = 0; i < 5; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    System.out.println("員工xxxx下班了");
                    countDownLatch.countDown();
                }
            }).start();
        }
    }
}

輸出結果：

再寫個例子：3y現在負責倉庫模塊功能，但是能力太差了，寫得很慢，別的員工都需要等3y寫好了才能繼續往下寫。


import java.util.concurrent.CountDownLatch;

public class Test {

    public static void main(String[] args) {

        final CountDownLatch countDownLatch = new CountDownLatch(1);

        // 3y線程啟動
        new Thread(new Runnable() {
            @Override
            public void run() {

                try {
                    Thread.sleep(5);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("3y終於寫完了");
                countDownLatch.countDown();

            }
        }).start();

        // 其他員工線程啟動
        for (int i = 0; i < 5; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    System.out.println("其他員工需要等待3y");
                    try {
                        countDownLatch.await();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println("3y終於寫完了，其他員工可以開始了！");
                }
            }).start();
        }
    }
}

輸出結果：

參考資料：

二、CyclicBarrier

2.1CyclicBarrier簡介

  • A synchronization aid that allows a set of threads to all wait for each other to reach a common barrier point. CyclicBarriers are useful in programs involving a fixed sized party of threads that must occasionally wait for each other. The barrier is called cyclic because it can be re-used after the waiting threads are released.

簡單來說：CyclicBarrier允許一組線程互相等待，直到到達某個公共屏障點。叫做cyclic是因為當所有等待線程都被釋放以後，CyclicBarrier可以被重用(對比於CountDownLatch是不能重用的)

使用說明：

  • CountDownLatch註重的是等待其他線程完成，CyclicBarrier註重的是：當線程到達某個狀態後，暫停下來等待其他線程，所有線程均到達以後，繼續執行。

2.2CyclicBarrier例子

例子：3y和女朋友約了去廣州夜上海吃東西，由於3y和3y女朋友住的地方不同，自然去的路徑也就不一樣了。於是他倆約定在體育西路地鐵站集合，約定等到相互見面的時候就發一條朋友圈。


import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class Test {

    public static void main(String[] args) {

        final CyclicBarrier CyclicBarrier = new CyclicBarrier(2);
        for (int i = 0; i < 2; i++) {

            new Thread(() -> {

                String name = Thread.currentThread().getName();
                if (name.equals("Thread-0")) {
                    name = "3y";
                } else {
                    name = "女朋友";
                }
                System.out.println(name + "到了體育西");
                try {

                    // 兩個人都要到體育西才能發朋友圈
                    CyclicBarrier.await();
                    // 他倆到達了體育西，看見了對方發了一條朋友圈：
                    System.out.println("跟" + name + "去夜上海吃東西~");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

測試結果：

玩了一天以後，各自回到家裡，3y和女朋友約定各自洗澡完之後再聊天


import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class Test {

    public static void main(String[] args) {

        final CyclicBarrier CyclicBarrier = new CyclicBarrier(2);
        for (int i = 0; i < 2; i++) {

            new Thread(() -> {

                String name = Thread.currentThread().getName();
                if (name.equals("Thread-0")) {
                    name = "3y";
                } else {
                    name = "女朋友";
                }
                System.out.println(name + "到了體育西");
                try {

                    // 兩個人都要到體育西才能發朋友圈
                    CyclicBarrier.await();
                    // 他倆到達了體育西，看見了對方發了一條朋友圈：
                    System.out.println("跟" + name + "去夜上海吃東西~");

                    // 回家
                    CyclicBarrier.await();
                    System.out.println(name + "洗澡");

                    // 洗澡完之後一起聊天
                    CyclicBarrier.await();

                    System.out.println("一起聊天");

                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

測試結果：

參考資料：

三、Semaphore

3.1Semaphore簡介

Semaphores are often used to restrict the number of threads than can access some (physical or logical) resource.

  • A counting semaphore. Conceptually, a semaphore maintains a set of permits. Each {@link #acquire} blocks if necessary until a permit is available, and then takes it. Each {@link #release} adds a permit,potentially releasing a blocking acquirer.However, no actual permit objects are used; the {@code Semaphore} just
    keeps a count of the number available and acts accordingly.

Semaphore(信號量)實際上就是可以控制同時訪問的線程個數，它維護了一組"許可證"。

  • 當調用acquire()方法時，會消費一個許可證。如果沒有許可證了，會阻塞起來
  • 當調用release()方法時，會添加一個許可證。
  • 這些"許可證"的個數其實就是一個count變數罷了~

3.2Semaphore例子

3y女朋友開了一間賣酸奶的小店，小店一次只能容納5個顧客挑選購買，超過5個就需要排隊啦~~~



import java.util.concurrent.Semaphore;

public class Test {

    public static void main(String[] args) {

        // 假設有50個同時來到酸奶店門口
        int nums = 50;

        // 酸奶店只能容納10個人同時挑選酸奶
        Semaphore semaphore = new Semaphore(10);

        for (int i = 0; i < nums; i++) {
            int finalI = i;
            new Thread(() -> {
                try {
                    // 有"號"的才能進酸奶店挑選購買
                    semaphore.acquire();

                    System.out.println("顧客" + finalI + "在挑選商品，購買...");

                    // 假設挑選了xx長時間，購買了
                    Thread.sleep(1000);

                    // 歸還一個許可，後邊的就可以進來購買了
                    System.out.println("顧客" + finalI + "購買完畢了...");
                    semaphore.release();



                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }).start();

        }

    }
}

輸出結果：

反正每次只能5個客戶同時進酸奶小店購買挑選。

參考資料：

四、總結

Java為我們提供了三個同步工具類：

  • CountDownLatch(閉鎖)
    • 某個線程等待其他線程執行完畢後，它才執行(其他線程等待某個線程執行完畢後，它才執行)
  • CyclicBarrier(柵欄)
    • 一組線程互相等待至某個狀態，這組線程再同時執行。
  • Semaphore(信號量)
    • 控制一組線程同時執行。

本文簡單的介紹了一下這三個同步工具類是幹嘛用的，要深入還得看源碼或者借鑒其他的資料。

最後補充一下之前的思維導圖知識點：

參考資料：

如果文章有錯的地方歡迎指正，大家互相交流。習慣在微信看技術文章，想要獲取更多的Java資源的同學，可以關註微信公眾號:Java3y。為了大家方便，剛新建了一下qq群：742919422，大家也可以去交流交流。謝謝支持了！希望能多介紹給其他有需要的朋友

文章的目錄導航：


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

-Advertisement-
Play Games
更多相關文章
  • 網站活動秒殺倒計時
    今天做移動端商城時候得，需要哥秒殺計時器，從後臺獲取了時間以後，前臺做相應的判斷。需要的可以直接拿去用，本人只精確到了x天x小時x分鐘x秒。其他需要可以自行添加。<!doctype html><html lang="en"><head> <meta charset="UTF-8"> <meta na ...
  • JQuery實現全選、全不選和反選功能
    看重點就行了，最後面給一個網頁完整的代碼 代碼實例： 全選： 反選： 全選操作案例： 數據遍歷出來： 點擊全選： 反選操作案例： 首先選中幾個 然後點擊反選： 附上完整網頁的代碼： ...
  • css把容器級別（div...）標簽固定在一個位置（在頁面最右邊）
    沒有滾動條時候： 有滾動條時候： ...
  • 函數式編程簡介-附入門方法
    函數式編程是一種解決問題的思路。我們熟悉的命令式編程把程式看作”一系列改變狀態的指令“；而函數式編程把程式看作”一系列數學函數映射的組合“。 ...
  • electron調用C#應用程式實現串口通信
    最近轉入零售行業開發了一系列產品，包含便利店收銀軟體、會員系統、供應鏈系統。為了追趕潮流，收銀軟體使用了electron平臺開發，界面效果、開發效率確實不錯；但是涉及到串口通訊時遇到了麻煩，electron不能直接使用node.js的串口模塊。網上有一些文章推薦編譯electron源碼來實現串口模塊 ...
  • 【代碼筆記】Web-ionic-Range
    一，效果圖。 二，代碼。 <!DOCTYPE html> <html> <head> <meta charset="utf-8"> <title>Todo</title> <meta name="viewport" content="initial-scale=1, maximum-scale=1, ...
  • 大型網站系統與java中間件實踐-閱讀筆記
    線程池 ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory thre ...
  • java 工廠模式
    1.工廠模式 工廠模式是我們最常用的實例化對象模式了，是用工廠方法代替new操作的一種模式。著名的Jive論壇 ,就大量使用了工廠模式，工廠模式在Java程式系統可以說是隨處可見。因為工廠模式就相當於創建實例對象的new，我們經常要根據類Class生成實例對象，如A a=new A() 工廠模式也是 ...
一周排行
    -Advertisement-
    Play Games
  • WPF 已知問題 監聽 WMI 事件導致觸摸失效
    示例項目結構 在 Visual Studio 中創建一個 WinForms 應用程式後，項目結構如下所示： MyWinFormsApp/ │ ├───Properties/ │ └───Settings.settings │ ├───bin/ │ ├───Debug/ │ └───Release/ ...
  • [STAThread]特性
    [STAThread] 特性用於需要與 COM 組件交互的應用程式，尤其是依賴單線程模型（如 Windows Forms 應用程式）的組件。在 STA 模式下，線程擁有自己的消息迴圈，這對於處理用戶界面和某些 COM 組件是必要的。 [STAThread] static void Main(stri ...
  • UWP WinUI3 傳入 AddHandler 的 RoutedEventHandler 類型與事件所需不匹配將拋出參數異常
    在WinForm中使用全局異常捕獲處理 在WinForm應用程式中，全局異常捕獲是確保程式穩定性的關鍵。通過在Program類的Main方法中設置全局異常處理，可以有效地捕獲並處理未預見的異常，從而避免程式崩潰。 註冊全局異常事件 [STAThread] static void Main() { / ...
  • .NET 多版本 WinForm 開源控制項庫 SunnyUI
    前言 給大家推薦一款開源的 Winform 控制項庫，可以幫助我們開發更加美觀、漂亮的 WinForm 界面。 項目介紹 SunnyUI.NET 是一個基於 .NET Framework 4.0+、.NET 6、.NET 7 和 .NET 8 的 WinForm 開源控制項庫，同時也提供了工具類庫、擴展 ...
  • .net core8 使用Swagger（附當前源碼）
    說明 該文章是屬於OverallAuth2.0系列文章，每周更新一篇該系列文章（從0到1完成系統開發）。 該系統文章，我會儘量說的非常詳細，做到不管新手、老手都能看懂。 說明：OverallAuth2.0 是一個簡單、易懂、功能強大的許可權+可視化流程管理系統。 有興趣的朋友，請關註我吧(*^▽^*) ...
  • WPF 什麼時候 VisualTreeHelper.GetDescendantBounds 將返回無窮大
    一、下載安裝 1.下載git 必須先下載並安裝git，再TortoiseGit下載安裝 git安裝參考教程：https://blog.csdn.net/mukes/article/details/115693833 2.TortoiseGit下載與安裝 TortoiseGit，Git客戶端，32/6 ...
  • C# 開源教程帶你輕鬆掌握數據結構與演算法
    前言 在項目開發過程中，理解數據結構和演算法如同掌握蓋房子的秘訣。演算法不僅能幫助我們編寫高效、優質的代碼，還能解決項目中遇到的各種難題。 給大家推薦一個支持C#的開源免費、新手友好的數據結構與演算法入門教程：Hello演算法。 項目介紹 《Hello Algo》是一本開源免費、新手友好的數據結構與演算法入門 ...
  • 第22篇 生成proto文件bat腳本
    1.生成單個Proto.bat內容 @rem Copyright 2016, Google Inc. @rem All rights reserved. @rem @rem Redistribution and use in source and binary forms, with or with ...
  • 記一次 .NET某上位機視覺程式 卡死分析
    一：背景 1. 講故事 前段時間有位朋友找到我，說他的窗體程式在客戶這邊出現了卡死，讓我幫忙看下怎麼回事？dump也生成了，既然有dump了那就上 windbg 分析吧。 二：WinDbg 分析 1. 為什麼會卡死 窗體程式的卡死，入口門檻很低，後續往下分析就不一定了，不管怎麼說先用 !clrsta ...
  • 醫學DICOM文件與PACS系統進行數據傳輸
    前言 人工智慧時代，人臉識別技術已成為安全驗證、身份識別和用戶交互的關鍵工具。 給大家推薦一款.NET 開源提供了強大的人臉識別 API，工具不僅易於集成，還具備高效處理能力。 本文將介紹一款如何利用這些API，為我們的項目添加智能識別的亮點。 項目介紹 GitHub 上擁有 1.2k 星標的 C# ...
所有分類