1. 程式人生 > 其它 >多執行緒(執行緒組【ThreadGroup】)

多執行緒(執行緒組【ThreadGroup】)

執行緒組: 把多個執行緒組合到一起。
* 它可以對一批執行緒進行分類管理,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();
    }
}