/**
 * 要實現的效果就是,有一個水池,水池的容量為50L,一個放水執行緒,負責放水,每200毫秒放出1L水,當水放完後,通知注水執行緒工作,同時放水執行緒停止工作;
 * 注水執行緒每200毫秒注水1L,水注滿時,再通知放水執行緒繼續工作,同時注水執行緒停止工作.
 * 
 * @author mChenys
 * 
 */
public class _Main5 {
	public static void main(String[] args) {
		Pool pool = new Pool();
		WaterIn in = new WaterIn(pool, "注水執行緒");
		WaterOut out = new WaterOut(pool, "放水執行緒");
		in.start();
		out.start();
	}
}

/**
 * 水池,容量為50L
 * 
 * @author mChenys
 * 
 */
class Pool {
	public int MAX_VLAUE = 50;
	public int curr_value = 0;
}

/**
 * 注水執行緒
 * 
 * @author mChenys
 * 
 */
class WaterIn extends Thread {
	private Pool pool;

	public WaterIn(Pool pool, String name) {
		super(name);
		this.pool = pool;
	}

	@Override
	public void run() {
		while (true) {
			synchronized (pool) {
				try {
					if (pool.curr_value < pool.MAX_VLAUE) {
						// 加水
						Thread.sleep(200);
						pool.curr_value += 1;
						System.out.println(this.getName() + "正在加水,加入 "
								+ pool.curr_value + " L水");
					} else if (pool.curr_value == pool.MAX_VLAUE) {

						System.out.println(this.getName()
								+ "水已加滿!!,可以放水了......");
						pool.notify();// 喚醒放水執行緒
						pool.wait();// 當前執行緒等待,釋放鎖物件
					}
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		}
	}
}

/**
 * 放水執行緒
 * 
 * @author mChenys
 * 
 */
class WaterOut extends Thread {
	private Pool pool;

	public WaterOut(Pool pool, String name) {
		super(name);
		this.pool = pool;
	}

	@Override
	public void run() {
		while (true) {
			synchronized (pool) {
				try {
					if (pool.curr_value > 0) {
						// 放水
						Thread.sleep(200);
						pool.curr_value -= 1;
						System.out.println(this.getName() + "開始放水,放出 "
								+ (pool.MAX_VLAUE - pool.curr_value) + " L水");

					} else if (pool.curr_value == 0) {
						System.out.println(this.getName() + "水已放完,可以加水了.....");
						pool.notify();// 喚醒注水執行緒
						pool.wait();// 當前執行緒等待,釋放鎖物件
					}
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		}
	}
}