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();              }          }                }  

?