Java多線程 中斷機(jī)制及實(shí)例詳解
正文
這里詳細(xì)分析interrupt(),interrupted(),isInterrupted()三個(gè)方法
interrupt()
中斷這個(gè)線程,設(shè)置中斷標(biāo)識(shí)位
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();
}
我們來(lái)找下如何設(shè)置中斷標(biāo)識(shí)位的
找到interrupt0()的源碼,src/hotspot/share/prims/jvm.cpp
JVM_ENTRY(void, JVM_Interrupt(JNIEnv* env, jobject jthread))
...
if (is_alive) {
// jthread refers to a live JavaThread.
Thread::interrupt(receiver);
}
JVM_END
調(diào)用了Thread::interrupt方法
src/hotspot/share/runtime/thread.cpp
void Thread::interrupt(Thread* thread) {
...
os::interrupt(thread);
}
os::interrupt方法,src/hotspot/os/posix/os_posix.cpp
void os::interrupt(Thread* thread) {
...
OSThread* osthread = thread->osthread();
if (!osthread->interrupted()) {
//設(shè)置中斷標(biāo)識(shí)位
osthread->set_interrupted(true);
...
}
...
}
isInterrupted()
測(cè)試線程是否被中斷,線程的中斷狀態(tài)不會(huì)改變
public boolean isInterrupted() {
return isInterrupted(false);
}
查看native isInterrupted(boolean ClearInterrupted)源碼,查找方式同上
src/hotspot/os/posix/os_posix.cpp
bool os::is_interrupted(Thread* thread, bool clear_interrupted) {
debug_only(Thread::check_for_dangling_thread_pointer(thread);)
OSThread* osthread = thread->osthread();
// 查看是否被中斷
bool interrupted = osthread->interrupted();
// 清除標(biāo)識(shí)位后再設(shè)置false
if (interrupted && clear_interrupted) {
osthread->set_interrupted(false);
}
return interrupted;
}
Java傳遞ClearInterrupted為false,對(duì)應(yīng)C++的clear_interrupted
interrupted()
測(cè)試線程是否被中斷,清除中斷標(biāo)識(shí)位
public static boolean interrupted() {
return currentThread().isInterrupted(true);
}
簡(jiǎn)單的例子
public class MyThread45 {
public static void main(String[] args) throws Exception
{
Runnable runnable = new Runnable()
{
public void run()
{
while (true)
{
if (Thread.currentThread().isInterrupted())
{
System.out.println("線程被中斷了");
return ;
}
else
{
System.out.println("線程沒(méi)有被中斷");
}
}
}
};
Thread t = new Thread(runnable);
t.start();
Thread.sleep(500);
t.interrupt();
System.out.println("線程中斷了,程序到這里了");
}
}
檢查線程是否中斷,中斷線程,運(yùn)行結(jié)果如下
······ 線程沒(méi)有被中斷 線程沒(méi)有被中斷 線程沒(méi)有被中斷 線程被中斷了 線程中斷了,程序到這里了
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Java日常練習(xí)題,每天進(jìn)步一點(diǎn)點(diǎn)(40)
下面小編就為大家?guī)?lái)一篇Java基礎(chǔ)的幾道練習(xí)題(分享)。小編覺(jué)得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧,希望可以幫到你2021-07-07
idea創(chuàng)建JAVA Class時(shí)自動(dòng)生成頭部文檔注釋的方法
這篇文章主要介紹了idea創(chuàng)建JAVA Class時(shí)自動(dòng)生成頭部文檔注釋的方法,本文通過(guò)圖文并茂的形式給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-12-12
因不會(huì)遠(yuǎn)程debug調(diào)試我被項(xiàng)目經(jīng)理嘲笑了
這篇文章主要介紹了遠(yuǎn)程debug調(diào)試的相關(guān)內(nèi)容,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2021-08-08
springboot集成WebSockets廣播消息(推薦)
這篇文章主要介紹了springboot-集成WebSockets廣播消息,本文給大家介紹的非常詳細(xì),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2019-12-12
Java設(shè)計(jì)模式中的建造者(Builder)模式解讀
這篇文章主要介紹了Java設(shè)計(jì)模式中的建造者(Builder)模式解讀, 建造者模式是一種創(chuàng)建對(duì)象的設(shè)計(jì)模式,它通過(guò)將對(duì)象的構(gòu)建過(guò)程分解為多個(gè)步驟,并使用一個(gè)建造者類來(lái)封裝這些步驟,從而使得對(duì)象的構(gòu)建過(guò)程更加靈活和可擴(kuò)展,需要的朋友可以參考下2023-10-10
如何利用java中String類的substring()字符串截取最后一個(gè)字符
Java中的String是不可變的類型,因此substring()方法并不會(huì)改變?cè)址?而是返回了一個(gè)新的字符串,這篇文章主要介紹了如何利用java中String類的substring()字符串截取最后一個(gè)字符,需要的朋友可以參考下2023-11-11
詳解Spring boot使用Redis集群替換mybatis二級(jí)緩存
本篇文章主要介紹了詳解Spring boot使用Redis集群替換mybatis二級(jí)緩存,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-05-05
詳解Java編程中線程同步以及定時(shí)啟動(dòng)線程的方法
這篇文章主要介紹了詳解Java編程中線程同步以及定時(shí)啟動(dòng)線程的方法, 講到了wait()與notify()方法以及阻塞隊(duì)列等知識(shí),需要的朋友可以參考下2016-01-01

