教學筆記:多線程之併發基礎-線程操作與組(四)

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); }}
教學筆記:多線程之併發基礎-線程操作與組(四)

join

線程組

如果只有一個士兵,直接指派就好了,如果有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)  

最後

這次是屬於上篇文章的查漏補缺。內容不多,但是也需要掌握。


分享到:


相關文章: