快捷導(dǎo)航

Java線程中的interrupt詳解

更新時(shí)間：2023年09月26日 08:31:26 作者：EileenChang

這篇文章主要介紹了Java線程中的interrupt詳解,interrupt翻譯成中文為“打斷”的意思,但實(shí)際上,interrupt()方法并非將一個(gè)線程打中斷的意思,本文提供了部分實(shí)現(xiàn)代碼,需要的朋友可以參考下

interrupt概念

interrupt翻譯成中文為“打斷”的意思，但實(shí)際上，interrupt()方法并非將一個(gè)線程打中斷的意思。查看Thread.interrupt()方法的源碼：

public void interrupt() {
        if (this != Thread.currentThread())
            checkAccess();
        synchronized (blockerLock) {
            Interruptible b = blocker;
            if (b != null) {
                interrupt0();           // Just to set the interrupt flag
                b.interrupt(this);
                return;
            }
        }
        interrupt0();
    }

從以上源碼可以知道，interrupt()方法只是設(shè)置了Thread對(duì)象中的一個(gè)標(biāo)志位而已(Just to set the interrupt flag)。它的意義在于，線程可以通過(guò)這個(gè)標(biāo)志位來(lái)決定需要做什么操作。

interrupt相關(guān)方法

interrupt()
打斷某個(gè)線程(設(shè)置標(biāo)志位)
isInterrupted()
查詢某個(gè)線程是否被打斷過(guò)(查詢標(biāo)志位)
interrupted()
查詢當(dāng)前線程是否被打斷過(guò)，并重置標(biāo)志位

public class TestThread {
    public static void main(String[] args) {
        Thread thread = new Thread(() -> {
            try {
                Thread.sleep(5000);
            } catch (InterruptedException e) {
                System.out.println("Thread is interrupted");
                System.out.println(Thread.currentThread().isInterrupted());
            }
        });
        thread.start();
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        thread.interrupt();
    }
}

輸出如下：

Thread is interrupted
false

可知當(dāng)線程sleep時(shí)，如果調(diào)用了interrupt()方法，將會(huì)拋出InterruptedException異常。捕獲異常之后，會(huì)重置interrupt標(biāo)志位。

wait、sleep、join與interrupt

當(dāng)一個(gè)線程在wait、sleep或join時(shí)，如果調(diào)用了其interrupt()方法，則會(huì)拋出InterruptedException異常。

synchronized與interrupt

當(dāng)一個(gè)線程在等待鎖的時(shí)候，其能否被interrupt打斷？

public class TestThread {
    public static void main(String[] args) {
        final Object o = new Object();
        new Thread(() -> {
            synchronized (o) {
                try {
                    Thread.sleep(5000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }).start();
        Thread thread = new Thread(() -> {
            System.out.println("thread 獲得鎖");
        });
        thread.start();
        thread.interrupt();
    }
}

輸出：

thread 獲得鎖

可知當(dāng)線程等待鎖時(shí)，并不會(huì)被打斷。

ReentrantLock與interrupt

public class TestThread {
    public static void main(String[] args) {
        Lock lock = new ReentrantLock();
        Thread t1 = new Thread(() -> {
            lock.lock();
            try {
                Thread.sleep(10000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            lock.unlock();
        });
        Thread t2 = new Thread(() -> {
            lock.lock();
            System.out.println("t2 獲得鎖");
            lock.unlock();
        });
        t1.start();
        t2.start();
        t2.interrupt();
    }
}

輸出：