多執行緒(執行緒組【ThreadGroup】)
阿新 • • 發佈:2022-04-05
執行緒組: 把多個執行緒組合到一起。
* 它可以對一批執行緒進行分類管理,Java允許程式直接對執行緒組進行控制。
package cn.itcast_06; public class MyRunnable implements Runnable { @Override public void run() { for (int x = 0; x < 100; x++) { System.out.println(Thread.currentThread().getName() + ":" + x); } } }
package cn.itcast_06; /* * 執行緒組: 把多個執行緒組合到一起。 * 它可以對一批執行緒進行分類管理,Java允許程式直接對執行緒組進行控制。 */ public class ThreadGroupDemo { public static void main(String[] args) { // method1(); // 我們如何修改執行緒所在的組呢? // 建立一個執行緒組 // 建立其他執行緒的時候,把其他執行緒的組指定為我們自己新建執行緒組 method2();// t1.start(); // t2.start(); } private static void method2() { // ThreadGroup(String name) //public ThreadGroup(String name)構造一個新執行緒組 //name - 新執行緒組的名稱。 ThreadGroup tg = new ThreadGroup("這是一個新的組"); MyRunnable my = new MyRunnable(); // Thread(ThreadGroup group, Runnable target, String name)//將執行緒t1放到執行緒組tg中並給執行緒分別取名為"林青霞","劉意" Thread t1 = new Thread(tg, my, "林青霞"); Thread t2 = new Thread(tg, my, "劉意"); //public final ThreadGroup getThreadGroup()返回該執行緒所屬的執行緒組並獲取此執行緒組的名稱 System.out.println(t1.getThreadGroup().getName()); System.out.println(t2.getThreadGroup().getName()); //通過組名稱設定後臺執行緒,表示該組的執行緒都是後臺執行緒 tg.setDaemon(true); } private static void method1() { MyRunnable my = new MyRunnable(); //public Thread(Runnable target,String name)分配新的 Thread 物件 //target - 其 run 方法被呼叫的物件。 //name - 新執行緒的名稱 Thread t1 = new Thread(my, "林青霞"); Thread t2 = new Thread(my, "劉意"); // 我不知道他們屬於那個執行緒組,我想知道,怎麼辦 //public final ThreadGroup getThreadGroup()返回該執行緒所屬的執行緒組 // 執行緒類裡面的方法:public final ThreadGroup getThreadGroup() ThreadGroup tg1 = t1.getThreadGroup(); ThreadGroup tg2 = t2.getThreadGroup(); // 執行緒組裡面的方法:public final String getName() String name1 = tg1.getName(); String name2 = tg2.getName(); System.out.println(name1); System.out.println(name2); // 通過結果我們知道了:執行緒預設情況下屬於main執行緒組 // 通過下面的測試,你應該能夠看到,默任情況下,所有的執行緒都屬於同一個組 System.out.println(Thread.currentThread().getThreadGroup().getName()); } }
生產者和消費者之等待喚醒機制的程式碼優化
package cn.itcast_07; public class Student { private String name; private int age; private boolean flag; // 預設情況是沒有資料,如果是true,說明有資料 public synchronized void set(String name, int age) { // 如果有資料,就等待 if (this.flag) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } // 設定資料 this.name = name; this.age = age; // 修改標記 this.flag = true;
//喚醒等待的單個執行緒 this.notify(); } public synchronized void get() { // 如果沒有資料,就等待 if (!this.flag) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } // 獲取資料 System.out.println(this.name + "---" + this.age); // 修改標記 this.flag = false; this.notify(); } }
執行緒實現類---設定和獲取資訊
package cn.itcast_07; public class SetThread implements Runnable { private Student s; private int x = 0; public SetThread(Student s) { this.s = s; } @Override public void run() { while (true) { if (x % 2 == 0) { s.set("林青霞", 27); } else { s.set("劉意", 30); } x++; } } }
package cn.itcast_07; public class GetThread implements Runnable { private Student s; public GetThread(Student s) { this.s = s; } @Override public void run() { while (true) { s.get(); } } }
測試
package cn.itcast_07; /* * 分析: * 資源類:Student * 設定學生資料:SetThread(生產者) * 獲取學生資料:GetThread(消費者) * 測試類:StudentDemo * * 問題1:按照思路寫程式碼,發現數據每次都是:null---0 * 原因:我們在每個執行緒中都建立了新的資源,而我們要求的時候設定和獲取執行緒的資源應該是同一個 * 如何實現呢? * 在外界把這個資料創建出來,通過構造方法傳遞給其他的類。 * * 問題2:為了資料的效果好一些,我加入了迴圈和判斷,給出不同的值,這個時候產生了新的問題 * A:同一個資料出現多次 * B:姓名和年齡不匹配 * 原因: * A:同一個資料出現多次 * CPU的一點點時間片的執行權,就足夠你執行很多次。 * B:姓名和年齡不匹配 * 執行緒執行的隨機性 * 執行緒安全問題: * A:是否是多執行緒環境 是 * B:是否有共享資料 是 * C:是否有多條語句操作共享資料 是 * 解決方案: * 加鎖。 * 注意: * A:不同種類的執行緒都要加鎖。 * B:不同種類的執行緒加的鎖必須是同一把。 * * 問題3:雖然資料安全了,但是呢,一次一大片不好看,我就想依次的一次一個輸出。 * 如何實現呢? * 通過Java提供的等待喚醒機制解決。 * * 等待喚醒: * Object類中提供了三個方法: * wait():等待 * notify():喚醒單個執行緒 * notifyAll():喚醒所有執行緒 * 為什麼這些方法不定義在Thread類中呢? * 這些方法的呼叫必須通過鎖物件呼叫,而我們剛才使用的鎖物件是任意鎖物件。 * 所以,這些方法必須定義在Object類中。 * * 最終版程式碼中: * 把Student的成員變數給私有的了。 * 把設定和獲取的操作給封裝成了功能,並加了同步。 * 設定或者獲取的執行緒裡面只需要呼叫方法即可。 */ public class StudentDemo { public static void main(String[] args) { //建立資源 Student s = new Student(); //設定和獲取的類 SetThread st = new SetThread(s); GetThread gt = new GetThread(s); //執行緒類 Thread t1 = new Thread(st); Thread t2 = new Thread(gt); //啟動執行緒 t1.start(); t2.start(); } }