Java多線程雖然知識點衆多,但抓住了基礎,也不難解決。
接着上一篇并發基礎,再說一些額外的知識點。上篇文章我們說了線程的狀态,還有線程的一些屬性。這次我們再說一些Thread類的用法,再說下線程組的概念。

線程的操作
這裡說下線程的一些其它操作。
中斷
在Java中,線程中斷是一種重要的線程協作機制。中斷不會使程式立刻退出,而是給線程發送一個通知,告訴目标線程,有人希望你退出了。至于目标線程收到通知後如何處理,則完全由目标線程自行決定。
// 中斷的方法
public static boolean Thread.interrupted() //靜态方法,判斷是否被中斷并對中斷标志位進行複位
public boolean Thread.interrupted() //判斷是否被中斷
public void Thread.interrupt() //中毒線程,隻改變中斷标志位
線上程運作的時候,若想要中斷起作用,必須要判斷中斷标志位才行。
public class InterruptTest {
public static void main(String[] args) throws InterruptedException {
Thread t1 = new Thread(() -> {
while (true){
if (Thread.currentThread().isInterrupted()){
System.out.println("interrupted");
break;
}
try {
Thread.sleep(2000);
}catch (InterruptedException e){
System.out.println("sleep 中斷異常");
// Thread.sleep由于中斷抛出異常,它會清除中斷标志位,是以要再中斷一次。
Thread.currentThread().interrupt();
}
}
});
t1.start();
Thread.sleep(2000);
t1.interrupt();
}
}
注意: Thread.sleep()方法由于中斷抛出異常,此時它會清除中斷标志位,如果不加處理,下次循環開始,就無法捕捉到這個中斷,是以在異常進行中,再次設定中斷标志位。
yield
public static native void yield();
這是一個靜态方法,一旦使用,它會使目前線程讓出CPU,也就是釋放目前搶占到的資源,然後再次和大家一起搶資源。
調用yield方法不代表線程把資源完全的讓給其它線程了,調用的線程有可能連續多次搶到資源的。這個方法基本上很少用。
join
根據名字,加入,也就是一個線程想要加入其它的線程,想要加入的話要怎麼辦呢?調用join的線程會一直執行直到完成。
如果t是一個正在運作的線程對象,調用t.join()的話,目前的線程會停止執行,一直等t線程執行完畢,才會開始。
join會對interrupt做出響應,如果調用了interrupt方法,會抛出中斷異常。
public class JoinTest {
public static int i = 0;
public static void main(String[] args) throws InterruptedException {
Thread t = new Thread(new Runnable() {
@Override
public void run() {
for (int j = 0; j < 100; j++) {
i++;
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
});
t.start();
// 如果沒有調用join方法,輸出的i會小于100
t.join();
System.out.println(i);
}
}
線程組
如果隻有一個士兵,直接指派就好了,如果有10個士兵,最好組成一個班。如果有50個士兵,最好組成一個排。
線程組也是一樣,如果有多個線程做相同的事情,最好給他們配置設定到某個線程組中。這樣既友善閱讀,也友善調試。
所有線程,預設都是放在
main
線程組中的。
在建立線程的時候,可以指定線程組。
// name為線程的名稱
// stackSize,建立的線程指定的棧大小
public Thread(ThreadGroup group, Runnable target);
public Thread(ThreadGroup group, Runnable target, String name)
public Thread(ThreadGroup group, Runnable target, String name,
long stackSize);
public Thread(ThreadGroup group, String name)
最後
這次是屬于上篇文章的查漏補缺。内容不多,但是也需要掌握。