java 线程同步例子(zt)
package test_1; public class BigSmallMonk { public static void main(String[] args) { WaterIntake Omonk=new WaterIntake(); PouringWater Ymonk=new PouringWater(); Thread Ymonk1=new Thread(Ymonk); Ymonk1.setName("Ymonk1"); Thread Omonk1=new Thread(Omonk); Omonk1.setName("Omonk1"); Ymonk1.start(); Omonk1.start(); } } class WaterTank//水缸 { static int num=30;//水缸所能承受水的桶数 static int currentNum=0;//水缸里现有的水的桶数 static boolean flag = true;//缸口是否有人使用 public void reduce()//取水 { synchronized (this) { while (!flag) { try { System.out.println("缸口有人使用"); this.wait(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } //这里不需要设置false，因为你这样一设置，另外一个线程总是执行那个while里并且在wait了。 //flag=false; try { Thread.sleep(1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } currentNum--; flag=true; this.notify(); System.out.println(Thread.currentThread().getName()+"取出了水"); } } public void push()//倒水 { synchronized (this) { while (!flag) { try { System.out.println("缸口有人使用"); this.wait(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } //这里不需要设置false，因为你这样一设置，另外一个线程总是执行那个while里并且在wait了。 //flag=false; try { Thread.sleep(1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } currentNum++; flag=true; this.notify(); System.out.println(Thread.currentThread().getName()+"倒入了一桶水"); } } } class WaterIntake implements Runnable//取水线程 { WaterTank water=new WaterTank(); public void run() { while (true) { water.reduce(); } } } class PouringWater implements Runnable//倒水线程 { WaterTank water=new WaterTank(); public void run() { while(true) { water.push(); } } } ?