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

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

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

一，Thread 的幾個(gè)常見屬性

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

Java中創(chuàng)建線程

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

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

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

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

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

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

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

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

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

關(guān)于后臺(tái)線程，需要記住一點(diǎn)：JVM會(huì)在一個(gè)進(jìn)程的所有非后臺(tái)線程結(jié)束后，才會(huì)結(jié)束運(yùn)行。

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

線程的中斷問題，下面我們進(jìn)一步說明

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());
        //這組屬性會(huì)隨著線程的運(yùn)行而開始改變
        System.out.println(t.isAlive());
        System.out.println(t.isInterrupted());
        System.out.println(t.getState());
 
        t.start();
 
        while (t.isAlive()){
            System.out.println("123 正在運(yùn)行");
            System.out.println(t.getState());
            System.out.println(t.isInterrupted());
            Thread.sleep(300);
        }
    }

二，線程調(diào)試

1，啟動(dòng)一個(gè)線程

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

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

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

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

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

2，中斷一個(gè)線程

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

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

2，任務(wù)執(zhí)行到一半，被強(qiáng)制結(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. 如果線程因?yàn)檎{(diào)用 wait/join/sleep 等方法而阻塞掛起，則以 InterruptedException 異常的形式通知，清除中斷標(biāo)志

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

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

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

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

這種方式通知收到的更及時(shí)，即使線程正在 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，等待一個(gè)線程

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());
    }