一篇文章掌握J(rèn)ava?Thread的類及其常見方法

更新時間：2022年03月02日 14:56:01 作者：/少司命

Thread類用于操作線程，是所以涉及到線程操作(如并發(fā))的基礎(chǔ)。本文將通過代碼對Thread類的功能作用及其常見方法進行分析

一，Thread 的幾個常見屬性

Thread 類是 JVM 用來管理線程的一個類，換句話說，每個線程都有一個唯一的 Thread 對象與之關(guān)聯(lián)。

Java中創(chuàng)建線程

顯示繼承Thread，重寫run方法來指定線程執(zhí)行的代碼

匿名內(nèi)部類來繼承Thread，重寫run方法來指定線程執(zhí)行的代碼

顯示實現(xiàn)Runnable接口，重寫run方法

匿名內(nèi)部類來繼承Runnable接口，重寫run方法

通過lambda表達式來描述執(zhí)行的代碼

屬性	獲取方法
ID	getId()
名稱	getNmame()
狀態(tài)	getState()
優(yōu)先級	getPriority()
是否后臺線程	isDaemon()
是否存活	isAlive()
是否被中斷	isInterrupted()

ID 是線程的唯一標(biāo)識，不同線程不會重復(fù)

名稱是各種調(diào)試工具用到狀態(tài)表示線程當(dāng)前所處的一個情況，下面我們會進一步說明

優(yōu)先級高的線程理論上來說更容易被調(diào)度到

關(guān)于后臺線程，需要記住一點：JVM會在一個進程的所有非后臺線程結(jié)束后，才會結(jié)束運行。

是否存活，即簡單的理解，為 run 方法是否運行結(jié)束了

線程的中斷問題，下面我們進一步說明

public static void main(String[] args) throws InterruptedException {
        Thread t = new Thread("123"){
            @Override
            public void run() {
                for (int i = 0; i < 10; i++){
                    System.out.println(Thread.currentThread().getName());
                    try{
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                System.out.println("線程退出");
            }
        };
 
        //這一組屬性，線程創(chuàng)建完成后，屬性就不變了
        System.out.println(t.getName());
        System.out.println(t.getPriority());
        System.out.println(t.isDaemon());
        System.out.println(t.getId());
        //這組屬性會隨著線程的運行而開始改變
        System.out.println(t.isAlive());
        System.out.println(t.isInterrupted());
        System.out.println(t.getState());
 
        t.start();
 
        while (t.isAlive()){
            System.out.println("123 正在運行");
            System.out.println(t.getState());
            System.out.println(t.isInterrupted());
            Thread.sleep(300);
        }
    }

二，線程調(diào)試

1，啟動一個線程

之前我們已經(jīng)看到了如何通過覆寫 run 方法創(chuàng)建一個線程對象，但線程對象被創(chuàng)建出來并不意味著線程就開始運行了。

覆寫 run 方法是提供給線程要做的事情的指令清單

線程對象可以認(rèn)為是把李四、王五叫過來了

而調(diào)用 start() 方法，就是喊一聲：”行動起來！“，線程才真正獨立去執(zhí)行了。

 static class MyThread extends Thread{
        @Override
        public void run() {
            System.out.println("我是一個線程");
        }
    }
 
    public static void main(String[] args) {
        Thread t = new MyThread();
        t.start();
    }

2，中斷一個線程

中斷讓一個程序結(jié)束，結(jié)束可能有兩種情況

1，已經(jīng)把任務(wù)執(zhí)行完了

2，任務(wù)執(zhí)行到一半，被強制結(jié)束

public static void main(String[] args) throws InterruptedException {
        Thread t = new Thread(){
            @Override
            public void run() {
               while (! isQuit){
                   System.out.println("正在轉(zhuǎn)賬");
                   try {
                       Thread.sleep(500);
                   } catch (InterruptedException e) {
                       e.printStackTrace();
                   }
               }
                System.out.println("轉(zhuǎn)賬終止");
            }
        };
        t.start();
        Thread.sleep(500);
        System.out.println("有內(nèi)鬼，終止交易");
        isQuit = true;
    
}

public static void main(String[] args) throws InterruptedException {
        Thread t = new Thread(){
            @Override
            public void run() {
                while (!Thread.interrupted()){
                    System.out.println("正在轉(zhuǎn)賬");
                    try {
                        Thread.sleep(5000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                        break;
                    }
                }
                System.out.println("轉(zhuǎn)賬終止");
            }
        };
        t.start();
        Thread.sleep(5000);
        System.out.println("有內(nèi)鬼，終止交易");
        t.interrupt();
    }

thread 收到通知的方式有兩種：

1. 如果線程因為調(diào)用 wait/join/sleep 等方法而阻塞掛起，則以 InterruptedException 異常的形式通知，清除中斷標(biāo)志

當(dāng)出現(xiàn) InterruptedException 的時候, 要不要結(jié)束線程取決于 catch 中代碼的寫法. 可以選擇忽略這個異常, 也可以跳出循環(huán)結(jié)束線程.

2.否則，只是內(nèi)部的一個中斷標(biāo)志被設(shè)置，thread 可以通過

Thread.interrupted() 判斷當(dāng)前線程的中斷標(biāo)志被設(shè)置，清除中斷標(biāo)志

Thread.currentThread().isInterrupted() 判斷指定線程的中斷標(biāo)志被設(shè)置，不清除中斷標(biāo)志

這種方式通知收到的更及時，即使線程正在 sleep 也可以馬上收到。

public static void main(String[] args) {
        Thread t = new Thread(){
            @Override
            public void run() {
                for (int i = 0; i < 10; i++){
                    System.out.println(Thread.interrupted());
                }
            }
        };
        t.start();
        t.interrupt();
    }

public static void main(String[] args) {
        Thread t = new Thread(){
            @Override
            public void run() {
                for (int i = 0; i < 10; i++){
                    System.out.println(Thread.currentThread().isInterrupted());
                }
            }
        };
        t.start();
        t.interrupt();
    }

3，等待一個線程

t1與t2串行執(zhí)行

 public static void main(String[] args) throws InterruptedException {
        Thread t1 = new Thread(){
            @Override
            public void run() {
                for (int i = 0; i < 10; i++){
                    System.out.println("我是線程1");
                    try {
                        Thread.sleep(50);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        };
 
 
        Thread t2 = new Thread(){
            @Override
            public void run() {
               for (int i = 0; i < 10; i++){
                   System.out.println("我是線程2");
                   try {
                       Thread.sleep(50);
                   } catch (InterruptedException e) {
                       e.printStackTrace();
                   }
               }
            }
        };
 
 
        t1.start();
        t1.join();
        t2.start();
        t2.join();
        System.out.println("主線程執(zhí)行完畢");
    }

t1與t2并發(fā)執(zhí)行

public static void main(String[] args) throws InterruptedException {
        Thread t1 = new Thread(){
            @Override
            public void run() {
                for (int i = 0; i < 10; i++){
                    System.out.println("我是線程1");
                    try {
                        Thread.sleep(50);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        };
 
 
        Thread t2 = new Thread(){
            @Override
            public void run() {
               for (int i = 0; i < 10; i++){
                   System.out.println("我是線程2");
                   try {
                       Thread.sleep(50);
                   } catch (InterruptedException e) {
                       e.printStackTrace();
                   }
               }
            }
        };
 
 
        t1.start();
        t2.start();
        t1.join();
        t2.join();
        System.out.println("主線程執(zhí)行完畢");
    }

4，休眠線程

public static void main(String[] args) throws InterruptedException {
        System.out.println(System.currentTimeMillis());
        Thread.sleep(1000);
        System.out.println(System.currentTimeMillis());
    }