Java多線程學習(Day02)

来源:https://www.cnblogs.com/CooperCode/archive/2023/09/17/17709026.html
-Advertisement-
Play Games

目錄 線程簡介 線程實現(重點) 線程狀態 線程同步(重點) 線程通信問題 線程實現: 方式一:繼承Thread類 /** * TODO * @author 清蓮孤舟 * @CreateDate 2023/9/17/9:28 * 創建線程的方式一:通過繼承Thread類實現 */ //繼承Threa ...


目錄

線程實現:

方式一:繼承Thread類

/**
 * TODO
 * @author 清蓮孤舟
 * @CreateDate 2023/9/17/9:28
 * 創建線程的方式一:通過繼承Thread類實現
 */
//繼承Thread類
public class demo01 extends Thread {
//重寫run方法
    @Override
    public void run() {
        for (int i = 0; i < 20; i++) {
            System.out.println("副線程"+i);
        }
    }
//main主線程
    public static void main(String[] args) {
        demo01 demo01 = new demo01();
        //start方法啟用線程
        demo01.start();
        //run()方法啟用線程
        demo01.run();
        for (int i = 0; i < 20; i++) {
            System.out.println("主線程"+i);
        }
    }
}

  我們先調用run方法運行(註意run()方法在主函數中的順序):

副線程0    副線程1    副線程2    副線程3    副線程4    副線程5    副線程6    副線程7    副線程8    副線程9    
副線程10    副線程11    副線程12    副線程13    副線程14    副線程15    副線程16    副線程17    副線程18    副線程19

主線程0    主線程1    主線程2    主線程3    主線程4    主線程5    主線程6    主線程7    主線程8    主線程9    
主線程10    主線程11    主線程12    主線程13    主線程14    主線程15    主線程16    主線程17    主線程18    主線程19    

  可以看出程式先運行完run線程再運行main主線程。符合程式按序執行的規制。同理如果將run()方法放在主函數的最後,那麼先輸出的將是"主線程"隨後是"副線程"。

  接下來我們調用start()方法:

主線程0    副線程0    主線程1    主線程2    主線程3    主線程4    副線程1    主線程5    主線程6    主線程7    副線程2    主線程8    主線程9    主線程10   主線程11   主線程12   副線程3    
主線程13 主線程14 主線程15 主線程16 主線程17 主線程18 主線程19 副線程4 副線程5 副線程6 副線程7 副線程8 副線程9 副線程10 副線程11 副線程12 副線程13
副線程14 副線程15 副線程16 副線程17 副線程18 副線程19

  顯而易見程式並不是按序執行的,而是交替並行的。這便是上節中介紹的併發,在一段時間內交替完成。

  (PS:如果你在運行時發現輸出結果並不是交替的,那麼請將for迴圈次數增加,20次迴圈對於你的電腦來說太簡單了)

方式二:實現Runnable介面(重點)

/**
 * TODO
 * @author Cooper
 * @CreateDate 2023/9/17/10:26
 * 創建線程方式二:實現Runnable介面
 */
public class demo02 implements Runnable{
//   同樣的重寫run()方法
    @Override
    public void run() {
        for (int i = 0; i < 20; i++) {
            System.out.print("副線程"+i+"\t");
        }
    }
    public static void main(String[] args) {
        demo02 demo02 = new demo02();
//        創建線程對象,通過線程對象開啟線程
        Thread thread = new Thread(demo02);
        thread.start();
//      可以簡寫為該寫法new Thread(demo02).start();
        for (int i = 0; i < 20; i++) {
            System.out.print("主線程"+i+"\t");
        }
    }
}

  源碼解析:

//Runnable源碼 只有一個run()方法
public interface Runnable {
    public abstract void run();
}
//Thread方法 需要傳入一個實現Runnable的對象
public Thread(Runnable target) {
    init(null, target, "Thread-" + nextThreadNum(), 0);
}

  運行結果:

主線程0    副線程0    主線程1    副線程1    主線程2    主線程3    主線程4    主線程5    副線程2    主線程6    
主線程7    主線程8    副線程3    主線程9    副線程4    主線程10    主線程11    主線程12    主線程13    主線程14    
主線程15    主線程16    主線程17    副線程5    主線程18    副線程6    副線程7    主線程19    副線程8    副線程9    
副線程10    副線程11    副線程12    副線程13    副線程14    副線程15    副線程16    副線程17    副線程18    副線程19    

線程併發案例:

  這裡使用狂神的案例:

 1 /**
 2  * TODO
 3  *
 4  * @author Cooper
 5  * @CreateDate 2023/9/17/10:42
 6  */
 7 public class demo03 implements Runnable{
 8     private int TicketNumber = 10;
 9     @Override
10     public void run() {
11         while (true){
12             if(TicketNumber==0){
13                 break;
14             }
15             try {
16                 //線程暫停200ms
17                 Thread.sleep(200);
18             } catch (InterruptedException e) {
19                 e.printStackTrace();
20             }
21             //Thread.currentThread().getName()獲取當前線程的名字
22             System.out.println(Thread.currentThread().getName()+"===>拿到了第"+TicketNumber--+"票");
23         }
24     }
25     public static void main(String[] args) {
26         demo03 ticket = new demo03();
27         new Thread(ticket,"小張").start();
28         new Thread(ticket,"小李").start();
29         new Thread(ticket,"小王").start();
30     }
31 }

  運行結果:

小李===>拿到了第8票
小張===>拿到了第10票
小王===>拿到了第9票
小王===>拿到了第6票
小李===>拿到了第7票
小張===>拿到了第7票
小李===>拿到了第3票
小王===>拿到了第4票
小張===>拿到了第5票
小李===>拿到了第2票
小王===>拿到了第2票
小張===>拿到了第2票
小張===>拿到了第1票
小王===>拿到了第1票
小李===>拿到了第1票

  此時我們發現了一些問題--->同一張票被兩個人拿到了! 這就是線程不安全,數據紊亂。後序我們將通過線程同步解決這個問題。

方式三:實現callable介面(瞭解即可)

 1 import java.util.ArrayList;
 2 import java.util.List;
 3 import java.util.concurrent.*;
 4 /**
 5  * TODO
 6  *
 7  * @author Cooper
 8  * @CreateDate 2023/9/17/14:52
 9  */
10 public class demo04 implements Callable<List<String>> {
11     @Override
12     public List<String> call() throws Exception {
13         List<String> result = new ArrayList<>();
14         for (int i = 0; i < 5; i++) {
15             result.add(Thread.currentThread().getName()+"===>"+i);
16             System.out.print(Thread.currentThread().getName()+"===>"+i+"\t");
17         }
18         return result;
19     }
20     public static void main(String[] args) throws ExecutionException, InterruptedException {
21         demo04 test1 = new demo04();
22         demo04 test2 = new demo04();
23         demo04 test3 = new demo04();
24 //        創建服務開啟三個線程
25         ExecutorService service = Executors.newFixedThreadPool(3);
26         System.out.println("運行中:");
27 //        提交執行
28         Future<List<String>> r1 = service.submit(test1);
29         Future<List<String>> r2 = service.submit(test2);
30         Future<List<String>> r3 = service.submit(test3);
31 //        獲取結果
32         List<String> result1 = r1.get();
33         List<String> result2 = r2.get();
34         List<String> result3 = r3.get();
35         System.out.println();
36 
37         System.out.println("運行結束:");
38         System.out.println(result1);
39         System.out.println(result2);
40         System.out.println(result3);
41 //        關閉服務
42         service.shutdown();
43     }
44 }

  運行結果:

運行中:
pool-1-thread-2===>0    pool-1-thread-1===>0    pool-1-thread-2===>1    pool-1-thread-3===>0    
pool-1-thread-2===>2    pool-1-thread-1===>1    pool-1-thread-2===>3    pool-1-thread-1===>2    
pool-1-thread-3===>1    pool-1-thread-1===>3    pool-1-thread-2===>4    pool-1-thread-1===>4    
pool-1-thread-3===>2    pool-1-thread-3===>3    pool-1-thread-3===>4    
運行結束:
[pool-1-thread-1===>0, pool-1-thread-1===>1, pool-1-thread-1===>2, pool-1-thread-1===>3, pool-1-thread-1===>4]
[pool-1-thread-2===>0, pool-1-thread-2===>1, pool-1-thread-2===>2, pool-1-thread-2===>3, pool-1-thread-2===>4]
[pool-1-thread-3===>0, pool-1-thread-3===>1, pool-1-thread-3===>2, pool-1-thread-3===>3, pool-1-thread-3===>4]

 

本文來自博客園,作者:Lollipop_pro,轉載請註明原文鏈接:https://www.cnblogs.com/CooperCode/p/17709026.html


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

-Advertisement-
Play Games
更多相關文章
  • 在MySQL中,高級查詢是指使用更複雜的查詢語句和操作符來檢索和操作資料庫中的數據。高級查詢可以幫助您更精確地找到所需的信息,並提高查詢的效率和靈活性。 以下是高級查詢的一些常見應用場景和意義: 連接多個表:使用JOIN操作符將多個表連接起來,以便在一次查詢中獲取相關聯的數據。這對於在多個表之間建立 ...
  • 背景: 隨著項目體量越來越大,用戶群體越來越多,用戶的聲音也越來越明顯;關於應用發版之後用戶無感知,導致用戶用的是仍然還是老版本功能,除非用戶手動刷新,否則體驗不到最新的功能;這樣的體驗非常不好,於是我們團隊針對該問題給出了相應的解決方案來處理;技術棧:vue3+ts+vite+ant-design ...
  • 相比用戶停留時間短、用完即走的 Web 頁面,桌面 QQ 用戶在一次登錄後,可能會掛機一周以上,這段期間,如果沒有嚴格控制好 QQ 記憶體占用,那麼結果可能是用戶交互響應變慢、甚至 Crash。在系統監控工具里,高記憶體占用也會被直觀地反映出來,帶來不好的口碑。MAC QQ 灰度期間,也聽到了一些用戶關... ...
  • 介紹 ESLint 是一個根據方案識別並報告 ECMAScript/JavaScript 代碼問題的工具,其目的是使代碼風格更加一致並避免錯誤。在很多地方它都與 JSLint 和 JSHint 類似,除了: ESLint 使用 Espree 對 JavaScript 進行解析。 ESLint 在代碼 ...
  • 這是一個講解DDD落地的文章系列,作者是《實現領域驅動設計》的譯者滕雲。本文章系列以一個真實的並已成功上線的軟體項目——碼如雲(https://www.mryqr.com)為例,系統性地講解DDD在落地實施過程中的各種典型實踐,以及在面臨實際業務場景時的諸多取捨。 本系列包含以下文章: DDD入門 ...
  • 系統設計之緩存五種策略 當我們在架構中引入緩存時,緩存和資料庫之間的同步就變得不可避免。 讓我們看看如何保持數據同步的五種常見策略。 1)閱讀策略: 緩存在一邊 通讀2)寫策略:寫周圍 回信 寫通緩存策略經常組合使用。例如,write-around 通常與 cache-aside 一起使用,以確保緩 ...
  • 前一篇水文中,老周演示了 QAbstractItemModel 抽象類的繼承方法。其實,在 Qt 的庫裡面,QAbstractItemModel 類也派生了兩個基類,能讓開發者繼承起來【稍稍】輕鬆一些。 這兩個類是 QAbstractListModel 和 QAbstractTableModel。 ...
  • 註釋可以用來解釋Python代碼。註釋可以用來使代碼更易讀。註釋可以用來在測試代碼時防止執行。 創建註釋 註釋以#開始,Python會忽略它們: 示例:獲取您自己的Python註釋 # 這是一個註釋 print("Hello, World!") 註釋可以放在一行的末尾,Python會忽略行的其餘部分 ...
一周排行
    -Advertisement-
    Play Games
  • PasteSpider是什麼? 一款使用.net編寫的開源的Linux容器部署助手,支持一鍵發佈,平滑升級,自動伸縮, Key-Value配置,項目網關,環境隔離,運行報表,差量升級,私有倉庫,集群部署,版本管理等! 30分鐘上手,讓開發也可以很容易的學會在linux上部署你得項目! [從需求角度介 ...
  • SQLSugar是什麼 **1. 輕量級ORM框架,專為.NET CORE開發人員設計,它提供了簡單、高效的方式來處理資料庫操作,使開發人員能夠更輕鬆地與資料庫進行交互 2. 簡化資料庫操作和數據訪問,允許開發人員在C#代碼中直接操作資料庫,而不需要編寫複雜的SQL語句 3. 支持多種資料庫,包括但 ...
  • 在C#中,經常會有一些耗時較長的CPU密集型運算,因為如果直接在UI線程執行這樣的運算就會出現UI不響應的問題。解決這類問題的主要途徑是使用多線程,啟動一個後臺線程,把運算操作放在這個後臺線程中完成。但是原生介面的線程操作有一些難度,如果要更進一步的去完成線程間的通訊就會難上加難。 因此,.NET類 ...
  • 一:背景 1. 講故事 前些天有位朋友在微信上丟了一個崩潰的dump給我,讓我幫忙看下為什麼出現了崩潰,在 Windows 的事件查看器上顯示的是經典的 訪問違例 ,即 c0000005 錯誤碼,不管怎麼說有dump就可以上windbg開幹了。 二:WinDbg 分析 1. 程式為誰崩潰了 在 Wi ...
  • CSharpe中的IO+NPOI+序列化 文件文件夾操作 學習一下常見的文件、文件夾的操作。 什麼是IO流? I:就是input O:就是output,故稱:輸入輸出流 將數據讀入記憶體或者記憶體輸出的過程。 常見的IO流操作,一般說的是[記憶體]與[磁碟]之間的輸入輸出。 作用 持久化數據,保證數據不再 ...
  • C#.NET與JAVA互通之MD5哈希V2024 配套視頻: 要點: 1.計算MD5時,SDK自帶的計算哈希(ComputeHash)方法,輸入輸出參數都是byte數組。就涉及到字元串轉byte數組轉換時,編碼選擇的問題。 2.輸入參數,字元串轉byte數組時,編碼雙方要統一,一般為:UTF-8。 ...
  • CodeWF.EventBus,一款靈活的事件匯流排庫,實現模塊間解耦通信。支持多種.NET項目類型,如WPF、WinForms、ASP.NET Core等。採用簡潔設計,輕鬆實現事件的發佈與訂閱。通過有序的消息處理,確保事件得到妥善處理。簡化您的代碼,提升系統可維護性。 ...
  • 一、基本的.NET框架概念 .NET框架是一個由微軟開發的軟體開發平臺,它提供了一個運行時環境(CLR - Common Language Runtime)和一套豐富的類庫(FCL - Framework Class Library)。CLR負責管理代碼的執行,而FCL則提供了大量預先編寫好的代碼, ...
  • 本章將和大家分享在ASP.NET Core中如何使用高級客戶端NEST來操作我們的Elasticsearch。 NEST是一個高級別的Elasticsearch .NET客戶端,它仍然非常接近原始Elasticsearch API的映射。所有的請求和響應都是通過類型來暴露的,這使得它非常適合快速上手 ...
  • 參考delphi的代碼更改為C# Delphi 檢測密碼強度 規則(仿 google) 仿 google 評分規則 一、密碼長度: 5 分: 小於等於 4 個字元 10 分: 5 到 7 字元 25 分: 大於等於 8 個字元 二、字母: 0 分: 沒有字母 10 分: 全都是小(大)寫字母 20 ...