執行緒組： 把多個執行緒組合到一起，
* 它可以對一批執行緒進行分類管理，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(); } }
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/456136.html
標籤：其他