import java.util.concurrent.locks.Condition;

import java.util.concurrent.locks.Lock;

import java.util.concurrent.locks.ReentrantLock;

/**

 * Lock下提供了一个condition条件，其中的condition提供了await和signal两个方法，

 * 起作用和Object提供的wait和notify相同，一个lock下可以有多个condition。

 *

 * @author

 *

 *    例子，使用lock实现互斥，condition实现通信，来做子线程打印10次，主线程打印100次，如此反复

 */

public class ConditionTest {

    public static void main(String[] args) {

        final Business business = new Business();

        new Thread(new Runnable() {

            @Override

            public void run() {

                while (true) {

                    business.sub();

                }

            }

        }).start();

        while (true) {

            business.main();

        }

    }

    // ConditionTest.Business

    static class Business {

        private Lock lock = new ReentrantLock();

        private Condition cond = lock.newCondition();

        private boolean flag = true; // true : main run , false : sub run

        public void main() {

            lock.lock();

            try {

                while (!flag) {

                    try {

                        cond.await();

                    } catch (InterruptedException e) {

                        e.printStackTrace();

                    }

                }

                for (int i = 1; i <= 100; i++) {

                    System.out.println("main of loop Number " + i);

                }

                flag = false;

                cond.signal();

            } finally {

                lock.unlock();

            }

        }

        public void sub() {

            lock.lock();

            try {

                while (flag) {

                    try {

                        cond.await();

                    } catch (InterruptedException e) {

                        e.printStackTrace();

                    }

                }

                for (int i = 1; i <= 10; i++) {

                    System.out.println("sub of loop Number" + i);

                }

                flag = true;

                cond.signal();

            } finally {

                lock.unlock();

            }

        }

    }

}