package com.ixhong.base.thread;import java.util.concurrent.locks.Condition;import java.util.concurrent.locks.Lock;import java.util.concurrent.locks.ReentrantLock;public class ThreeConditionCommunication {   /**    * @param args*/public static void main(String[] args) {            final Business business = new Business();      new Thread(            new Runnable() {                              @Overridepublic void run() {                                 for(int i=1;i<=50;i++){                     business.sub2(i);                  }                                 }            }      ).start();            new Thread(            new Runnable() {                              @Overridepublic void run() {                                 for(int i=1;i<=50;i++){                     business.sub3(i);                  }                                 }            }      ).start();                for(int i=1;i<=50;i++){         business.main(i);      }         }   static class Business {         Lock lock = new ReentrantLock();         Condition condition1 = lock.newCondition();         Condition condition2 = lock.newCondition();         Condition condition3 = lock.newCondition();        private int shouldSub = 1;        public  void sub2(int i){           lock.lock();           try{              while(shouldSub != 2){                 try {                  condition2.await();               } catch (Exception e) {                  // TODO Auto-generated catch blocke.printStackTrace();               }              }               for(int j=1;j<=10;j++){                  System.out.println("sub2 thread sequence of " + j + ",loop of " + i);               }              shouldSub = 3;              condition3.signal();           }finally{              lock.unlock();           }        }        public  void sub3(int i){           lock.lock();           try{              while(shouldSub != 3){                 try {                  condition3.await();               } catch (Exception e) {                  // TODO Auto-generated catch blocke.printStackTrace();               }              }               for(int j=1;j<=20;j++){                  System.out.println("sub3 thread sequence of " + j + ",loop of " + i);               }              shouldSub = 1;              condition1.signal();           }finally{              lock.unlock();           }        }                         public  void main(int i){           lock.lock();           try{             while(shouldSub != 1){                  try {                     condition1.await();                  } catch (Exception e) {                     // TODO Auto-generated catch blocke.printStackTrace();                  }               }               for(int j=1;j<=100;j++){                  System.out.println("main thread sequence of " + j + ",loop of " + i);               }               shouldSub = 2;               condition2.signal();        }finally{           lock.unlock();        }     }      }}