//进水
class Inflow implements Runnable{ //水对象
Water wat;
public Inflow(Water w){
this.wat = w;
} @Override
public void run() {
//进水
while (true) {
synchronized (wat) {
while (true) {
if (wat.count >= 50) {
wat.notify();
try {
wat.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
try {
//睡眠线程
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
wat.count++;
System.out.println("现在是在进水，水量为：" + wat.count);
}
} }
}
} //出水
class Outflow implements Runnable{ Water wat;
public Outflow(Water w){
this.wat = w;
} @Override
public void run() {
//出水
while (true) {
//线程锁
synchronized (wat) {
while (true) {
if (wat.count <= 0) {
wat.notify();
try {
wat.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
wat.count--;
System.out.println("现在是在放水，剩余水量为：" + wat.count);
}
} }
}
}
class Water{ int count = 50; }
public class demo5 { public static void main(String[] args) {
//创建水对象
Water Water = new Water();
//进水对象
Inflow in = new Inflow(Water);
//放水对象
Outflow out = new Outflow(Water); //
Thread thread = new Thread(in);
Thread the = new Thread(out); //开启线程
thread.start();
the.start();
} }