Java多線(xiàn)程之Interrupt中斷線(xiàn)程詳解

目錄

一、測試代碼

二、測試

為了方便理解簡(jiǎn)介中 interrupt 的概念, 寫(xiě)個(gè) DEMO 測試一下

 /**
 * 調用 interrupt 并不會(huì )影響線(xiàn)程正常運行
 */
@Test
public void testInvokeInterrupt() throws InterruptedException {
    Thread t1 = new Thread(() -> {
    for (int i = 0; ; i++) {
    log.info(i + "");
    }
    });
    t1.start();
    // 確保 t1.start() 成功執行
    Thread.sleep(1);
    log.info("interrupt 前 t1 interrupt 狀態(tài) = {}", t1.isInterrupted());
    t1.interrupt();
    log.info("interrupt 后 t1 interrupt 狀態(tài) = {}", t1.isInterrupted());
    log.info("t1 是否存活 = {}", t1.isAlive());
}

三、執行過(guò)程描述

• 首先 main 線(xiàn)程中啟動(dòng) t1線(xiàn)程
• t1 線(xiàn)程死循環(huán)輸出 i++
• main 線(xiàn)程確保 t1.start() 執行后
• 打印 t1 線(xiàn)程的線(xiàn)程中斷狀態(tài)
• 調用 t1.interrupt() 方法使線(xiàn)程中斷
• 打印 t1 線(xiàn)程的線(xiàn)程中斷狀態(tài)

四、輸出日志

ignore logs ......
20:29:57.632 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - 2561
20:29:57.633 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - 2562
20:29:57.633 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - 2563
20:29:57.486 [main] INFO cn.diswares.blog.interrupt.InterruptTests - interrupt 前 t1 interrupt 狀態(tài) = false
20:29:57.633 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - 2564
20:29:57.633 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - 2565
20:29:57.633 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - 2566
20:29:57.633 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - 2567
20:29:57.633 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - 2568
20:29:57.633 [main] INFO cn.diswares.blog.interrupt.InterruptTests - interrupt 后 t1 interrupt 狀態(tài) = true
20:29:57.633 [main] INFO cn.diswares.blog.interrupt.InterruptTests - t1 是否存活 = true
20:29:57.633 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - 2569
20:29:57.633 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - 2570
20:29:57.633 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - 2571
ignore logs ......

現象描述

• 調用 t1.interrupt() 執行前線(xiàn)程的 interrupt 狀態(tài)為 false
• 調用 t1.interrupt() 執行后線(xiàn)程的 interrupt 狀態(tài)為 true
• 線(xiàn)程并沒(méi)有被中斷, 可以成功死循環(huán)輸出循環(huán)次數

五、結論

Interrupt 的真正作用是給線(xiàn)程對象設置一個(gè)中斷標記, 并不會(huì )影響線(xiàn)程的正常運行

六、主要方法釋義

new Thread().interrupt()

中斷此線(xiàn)程（此線(xiàn)程不一定是當前線(xiàn)程，而是指調用該方法的Thread實(shí)例所代表的線(xiàn)程），但實(shí)際上只是給線(xiàn)程設置一個(gè)中斷標志，線(xiàn)程仍會(huì )繼續運行。

Thread.interrupted()

注意: 這是個(gè)靜態(tài)方法
測試當前線(xiàn)程是否被中斷(檢查中斷標志), 返回一個(gè)當前線(xiàn)程的 interrupt 狀態(tài), 并重置.
當我們第二次調用時(shí)中斷狀態(tài)已經(jīng)被重置, 將返回一個(gè)false
為了方便理解. 寫(xiě)一個(gè) DEMO

七、DEMO

DEMO 非常簡(jiǎn)單, 調用兩次 Thread.interrupted() 觀(guān)察 main 線(xiàn)程的 interrupt 標記

/**
 * 二次調用 t1.interrupted()
 */
@Test
public void testDoubleInvokeInterrupted () throws InterruptedException {
    Thread.currentThread().interrupt();
    log.info("interrupted1 = {}", Thread.interrupted());
    log.info("interrupted2 = {}", Thread.interrupted());
}

輸出日志

21:06:33.397 [main] INFO cn.diswares.blog.interrupt.InterruptTests - interrupted1 = true
21:06:33.402 [main] INFO cn.diswares.blog.interrupt.InterruptTests - interrupted2 = false

八、拓展程序

由于是靜態(tài)方法. 我們來(lái)看一下另一個(gè)小程序.

• 跟之前一樣將 t1 程序中斷
• 調用 t1.interrupted()
• 注意這里是個(gè)靜態(tài)方法

/**
 * 在主線(xiàn)程中調用 t1.interrupted()
 */
@Test
public void testMainInterrupted() throws InterruptedException {
    Thread t1 = new Thread(() -> {
        for (int i = 0; ; i++) {
            log.info("t1 is live");
        }
    });

    t1.start();
    Thread.sleep(1);
    t1.interrupt();
    Thread.sleep(1);
    log.info("{}", t1.interrupted());
}

拓展程序日志

ignore logs ......
21:11:20.504 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - t1 is live
21:11:20.504 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - t1 is live
21:11:20.490 [main] INFO cn.diswares.blog.interrupt.InterruptTests - false
21:11:20.504 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - t1 is live
21:11:20.504 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - t1 is live
21:11:20.504 [Thread-1] INFO cn.diswares.blog.interrupt.InterruptTests - t1 is live
ignore logs ......

拓展程序結論

• Thread.interrupted() 方法是靜態(tài)方法
• 它的實(shí)現為 Thread.currentThread(), 獲取的是當前正在執行的線(xiàn)程, JDK 原文注釋如下

Returns a reference to the currently executing thread object.

Returns: the currently executing thread.

• 所以這里 t1.interrupted() 返回的其實(shí)是 main 線(xiàn)程的線(xiàn)程中斷標記

new Thread().isInterrupted()

返回線(xiàn)程對象的中斷標記, 不會(huì )改變中斷標記

• true: 中斷標記存在
• false: 未設置中斷標記狀態(tài)

優(yōu)雅的結束一個(gè)線(xiàn)程

在 Java 中結束一個(gè)線(xiàn)程一般有下面三種手段:

• (禁用) Thread.stop() 這個(gè)方法已經(jīng)被廢棄. 因為這種結束線(xiàn)程的方式過(guò)于暴力. 會(huì )將當前線(xiàn)程暴力終結. 同時(shí)線(xiàn)程持有的鎖也都會(huì )釋放, 并且用戶(hù)有任何額外的處理來(lái)控制, 會(huì )導致數據不一致
• volatile: 外部申明 volatile 開(kāi)關(guān)變量, 當開(kāi)關(guān)條件不滿(mǎn)足時(shí)結束
• (推薦) interrupt: 最優(yōu)雅的方案

九、實(shí)戰

最初的 DEMO 是個(gè)死循環(huán), 那我們對其改造一下. 讓它能夠優(yōu)雅的結束

/**
 * 調用 interrupt 并不會(huì )影響線(xiàn)程正常運行
 */
@Test
public void testGracefulEndThread() throws InterruptedException {
    Thread t1 = new Thread(() -> {
        for (int i = 0; ; i++) {
            if (Thread.currentThread().isInterrupted()) {
                log.info("{} = true, i = {}", Thread.currentThread().getName(), i);
                break;
            } else {
                log.info("{} = false, i = {}", Thread.currentThread().getName(), i);
            }
        }
    });
    t1.start();
    // 確保 t1.start() 成功執行
    TimeUnit.SECONDS.sleep(1);
    t1.interrupt();
    TimeUnit.SECONDS.sleep(1);
    log.info(t1.getState().toString());
}

到此這篇關(guān)于Java多線(xiàn)程之Interrupt中斷線(xiàn)程詳解的文章就介紹到這了,更多相關(guān)Java Interrupt中斷線(xiàn)程內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！