By GokiSoft.com|
14:51 07/11/2022|
Java Advanced
[Source Code] Đồng bộ 3 Thread - C2109I
T1: sinh ngau nhien 1 so tu nhien N (0->20)
Neu rad: chan -> T2: in ra binh phuong
Neu ra: le -> T3: in so lap phuong
T1:.....6..... ......3....... .......1........
T2: ......36......
T3: ......9......... .......1......
T4:
T5:
T6:
T7:
T8:
Trong TH dong 3 Thread -> xu ly nhu the nao???
#Main.java
/*
* Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
* Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
*/
package java2.lesson05;
/**
*
* @author diepvan
*/
public class Main {
public static void main(String[] args) {
SharedData sharedData = new SharedData();
Thread1 t1 = new Thread1(sharedData);
Thread2 t2 = new Thread2(sharedData);
Thread3 t3 = new Thread3(sharedData);
t1.start();
t2.start();
t3.start();
}
}
#SharedData.java
/*
* Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
* Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
*/
package java2.lesson05;
/**
*
* @author diepvan
*/
public class SharedData {
public static final int THREAD_1 = 1;
public static final int THREAD_2 = 2;
public static final int THREAD_3 = 3;
int currentThread = THREAD_1;
int rad;
boolean live = true;
public int getRad() {
return rad;
}
public void setRad(int rad) {
this.rad = rad;
}
public int getCurrentThread() {
return currentThread;
}
public void setCurrentThread(int currentThread) {
this.currentThread = currentThread;
}
public boolean isLive() {
return live;
}
public void setLive(boolean live) {
this.live = live;
}
}
#Thread1.java
/*
* Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
* Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
*/
package java2.lesson05;
import java.util.Random;
import java.util.logging.Level;
import java.util.logging.Logger;
/**
*
* @author diepvan
*/
public class Thread1 extends Thread{
SharedData sharedData;
public Thread1(SharedData sharedData) {
this.sharedData = sharedData;
}
@Override
public void run() {
try {
Thread.sleep(100);
} catch (InterruptedException ex) {
Logger.getLogger(Thread1.class.getName()).log(Level.SEVERE, null, ex);
}
Random random = new Random();
for (int i = 0; i < 20; i++) {
synchronized (sharedData) {
int rad = random.nextInt(20);
sharedData.setRad(rad);
System.out.println("T1: " + rad);
if(rad % 2 == 0) {
sharedData.setCurrentThread(SharedData.THREAD_2);
} else {
sharedData.setCurrentThread(SharedData.THREAD_3);
}
sharedData.notifyAll();
try {
while(sharedData.getCurrentThread() != SharedData.THREAD_1) {
sharedData.wait();
}
} catch (InterruptedException ex) {
Logger.getLogger(Thread1.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
sharedData.setLive(false);
synchronized (sharedData) {
sharedData.notifyAll();
}
System.out.println("T1 stop");
}
}
#Thread2.java
/*
* Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
* Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
*/
package java2.lesson05;
import java.util.logging.Level;
import java.util.logging.Logger;
/**
*
* @author diepvan
*/
public class Thread2 extends Thread {
SharedData sharedData;
public Thread2(SharedData sharedData) {
this.sharedData = sharedData;
}
@Override
public void run() {
while (sharedData.isLive()) {
synchronized (sharedData) {
sharedData.notifyAll();
try {
while(sharedData.getCurrentThread() != SharedData.THREAD_2 && sharedData.isLive()) {
sharedData.wait();
}
if(!sharedData.isLive()) {
break;
}
} catch (InterruptedException ex) {
Logger.getLogger(Thread1.class.getName()).log(Level.SEVERE, null, ex);
}
int rad = sharedData.getRad();
System.out.println("T2: " + rad * rad);
sharedData.setCurrentThread(SharedData.THREAD_1);
}
}
synchronized (sharedData) {
sharedData.notifyAll();
}
System.out.println("T2 stop");
}
}
#Thread3.java
/*
* Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
* Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
*/
package java2.lesson05;
import java.util.logging.Level;
import java.util.logging.Logger;
/**
*
* @author diepvan
*/
public class Thread3 extends Thread{
SharedData sharedData;
public Thread3(SharedData sharedData) {
this.sharedData = sharedData;
}
@Override
public void run() {
while (sharedData.isLive()) {
synchronized (sharedData) {
sharedData.notifyAll();
try {
while(sharedData.getCurrentThread() != SharedData.THREAD_3 && sharedData.isLive()) {
sharedData.wait();
}
if(!sharedData.isLive()) {
break;
}
} catch (InterruptedException ex) {
Logger.getLogger(Thread1.class.getName()).log(Level.SEVERE, null, ex);
}
int rad = sharedData.getRad();
System.out.println("T3: " + rad * rad * rad);
sharedData.setCurrentThread(SharedData.THREAD_1);
}
}
System.out.println("T3 stop");
}
}
Tags:
Phản hồi từ học viên
5
(Dựa trên đánh giá ngày hôm nay)