Já tentei utilizar os métodos wait()
com notify
e até mesmo os métodos depreciados stop()
, e não obtive sucesso.
Possuo três (3) threads as quais são:
TankController
FaucetFill
FaucetEmpty
O que eu estou tentando fazer é simplesmente o seguinte:
a) O TankController controla as threads FaucetFill e FaucetEmpty.
b) A FaucetFill tem uma vazão de água de 10 litros á cada 150ms.
c) A FaucetEmpty tem uma vazão de água de 30 litros á cada 150ms.
Como funciona o TankController?
a) O controlador do tanque é responsável por abrir e fechar as torneiras.
b) Quando o tanque atinge seu volume máximo, a torneira de enchimento é fechada e a torneira de esvaziamento é aberta.
c) Quando o tanque estiver abaixo de 50% do seu volume a torneira de enchimento deverá ser aberta.
d) Quando o volume de água ficar abaixo da torneira de esvaziamento, essa torneira deverá ser fechada.
Qual problema que estou tendo?
Não consigo manipular corretamente as threads FaucetFill e FaucetEmpty dentro da thread TankController para poder abrir e fechar a torneira em sua determinada condição.
Main.java
public class Main {
public static void main(String[] args) {
Tank t = new TankWater();
FaucetFill ff = new FaucetFill(t);
FaucetEmpty fe = new FaucetEmpty(t);
TankController tc = new TankController(t, ff, fe);
ff.start();
fe.start();
tc.start();
}
}
TankController.java
public class TankController extends Thread {
private final TankWater tank;
private final FaucetFill ff;
private final FaucetEmpty fe;
public TankController(Tank t, FaucetFill ff, FaucetEmpty fe) {
this.tank = t;
this.ff = ff;
this.fe = fe;
}
@Override
public void run() {
System.out.println("TANK-CONTROLLER RUNNING!");
// CÓDIGO DE CONTROLE DAS TORNEIRAS
}
}
FaucetFill.java
public class FaucetFill extends Thread {
private final TankWater tank;
private final int timer = 150;
private int litersWater = 10;
private boolean isStarted;
public FaucetFill(Tank t) {
this.tank = t;
}
public void setIsStarted(boolean state) {
this.isStarted = state;
}
@Override
public void run() {
while(this.isStarted) {
System.out.println("FAUCETFILL RUNNING");
Thread.currentThread().sleep(this.timer);
this.tank.setAmountWater(this.litersWater);
}
}
}
FaucetEmpty.java
public class FaucetEmpty extends Thread {
private final TankWater tank;
private final int timer = 150;
private int litersWater = 30;
private boolean isStarted;
public FaucetEmpty(Tank t) {
this.tank = t;
}
public void setIsStarted(boolean state) {
this.isStarted = state;
}
@Override
public void run() {
while(this.isStarted) {
System.out.println("FAUCETEMPTY RUNNING");
Thread.currentThread().sleep(this.timer);
this.tank.removeWater(this.litersWater);
}
}
}
TankWater.java
import java.math.BigDecimal;
public class TankWater {
private final int maximumCapacity = 2000;
private int amountWater = 0;
public int getAmountWater() {
return amountWater;
}
public void setAmountWater(int amountWater) {
if(this.getPercentageWater() != 100)
this.amountWater += amountWater;
}
public void removeWater(int quantity) {
if(this.getAmountWater() - quantity >= 0)
this.setAmountWater(this.getAmountWater() - quantity);
}
public double getPercentageWater() {
BigDecimal value = new BigDecimal(this.maximumCapacity);
BigDecimal rate = new BigDecimal(this.getAmountWater());
BigDecimal percentage = rate.divide(value).multiply(new BigDecimal("100"));
return percentage.doubleValue();
}
}
TankWater
não estendeThread
, porque você diz que ele é uma Thread? Pelo que vejo ele é acessado por Threads. Note também que o seusetAmountWater(int amountWater)
não protege o tanque de "transbordar" (mesmo se o tanque estiver vazio e você passar como argumento 3000 o tanque ficará com 3mil litros, bem acima da capacidade e portanto em um estado inconsistente); esse problema também vai ocorrer se ele estiver com uns 1995 litros e aFaucetFill
adicionar +10 litros, ele vai para 2005 litros.