By GokiSoft.com| 16:58 27/03/2020|
Java Advanced

Share Code - Thread - MultiThread - Synchonized wait notify notifyAll trong java



- Synchonized
- wait, notify, notifyAll => run

Bài tập
- T1 >> sinh ngẫu nhiên 1 số tự nhiên từ 1-100
- T2 >> hiển thị bình phương số đã được sinh từ T1
1. Tạo 2 thread thực hiện yêu cầu trên
2. Đồng bộ luồng
T1 thực hiện > rad > T1 đợi T2 > hiển thị bình phương số rad > in ra màn hình > T2 wait > T1 chạy => vòng tròn như trên
3. Sinh ngẫu nhiên 10 sô => stop 2 luồng.

=> Phân tích
T1 > rad => lưu trữ
T2 > lấy số rad => hiển thị
=> DataMgr => SharedData

= Giải thích
T1 => chạy tới >> synchronized >> chiếm quyền xử lý đầu tiên
T2 => tới synchronized sau => đợi (queue)

T1 > sinh số ngẫu nhiên => Shared Data => hiển thị => gọi tới notifyAll (wait) => T2 vẫn ở trạng chờ (queue) => T1 => wait
T2 => được chạy vào => T2 => T2 notifyAll => T1 sẵn sàng >> T2 vào wait >> T1 được chạy >> ...



/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package java2.lession4;

/**
 *
 * @author Diep.Tran
 */
public class SharedData {
    int rad;

    public SharedData() {
    }

    public int getRad() {
        return rad;
    }

    public void setRad(int rad) {
        this.rad = rad;
    }
}




/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package java2.lession4;

import java.util.Random;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author Diep.Tran
 */
public class ThreadRandom extends Thread{
    SharedData sharedData;

    public ThreadRandom(SharedData sharedData) {
        this.sharedData = sharedData;
    }

    @Override
    public void run() {
        try {
            Thread.sleep(200);
        } catch (InterruptedException ex) {
            Logger.getLogger(ThreadRandom.class.getName()).log(Level.SEVERE, null, ex);
        }
        
        Random random = new Random();
        
        for (int i = 0; i < 10; i++) {
//            System.out.println("T1 >> " + i);
            synchronized(sharedData) {
                int rad = random.nextInt(100) + 1;
                sharedData.setRad(rad);
                System.out.println("Rad : " + rad);
                //trien khai them
                //wait => T2 chay.
                sharedData.notifyAll();
                try {
                    sharedData.wait();
                } catch (InterruptedException ex) {
                    Logger.getLogger(ThreadRandom.class.getName()).log(Level.SEVERE, null, ex);
                }
            }
        }
        System.out.println("T1 Stop");
        //stop
        //stop
        synchronized(sharedData) {
            sharedData.notifyAll();
        }
    }
}




/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package java2.lession4;

import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author Diep.Tran
 */
public class ThreadSquare extends Thread{
    SharedData sharedData;

    public ThreadSquare(SharedData sharedData) {
        this.sharedData = sharedData;
    }

    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
//            System.out.println("T2 >> " + i);
            synchronized(sharedData) {
                try {
                    sharedData.notifyAll();
                    sharedData.wait();
                } catch (InterruptedException ex) {
                    Logger.getLogger(ThreadSquare.class.getName()).log(Level.SEVERE, null, ex);
                }
                int rad = sharedData.getRad();
                rad *= rad;
                System.out.println("PT: " + rad);
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException ex) {
                    Logger.getLogger(ThreadRandom.class.getName()).log(Level.SEVERE, null, ex);
                }
            }
        }
        
        System.out.println("T2 Stop");
        //stop
        synchronized(sharedData) {
            sharedData.notifyAll();
        }
    }
    
    
}




/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package java2.lession4;

/**
 *
 * @author Diep.Tran
 */
public class Test2 {
    public static void main(String[] args) {
        SharedData sharedData = new SharedData();
        
        ThreadRandom threadRandom = new ThreadRandom(sharedData);
        ThreadSquare threadSquare = new ThreadSquare(sharedData);
        
        threadSquare.start();
        threadRandom.start();
    }
}


Tags:

Phản hồi từ học viên

5

(Dựa trên đánh giá ngày hôm nay)