condition线程之间的通信

Condition是java提供线程之间的一个通信机制，替换掉了Object当中的wait、notifly方法，相对于来说比较简单。

package thread;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class ConditionTest {
	public static void main(String[] args) {
		final ThreadTask threadTask = new ThreadTask();//业务任务对象
		new Thread(new Runnable() {
			@Override
			public void run() {
				for(int i=0;i<50;i++){
					threadTask.loopTask();//子线程任务
				}
			}
		}).start();
		for(int i=0;i<50;i++){
			threadTask.mainTask();//主线程任务
		}
	}
}

class ThreadTask{
	private boolean flag = true;//主线程、子线程运行标志
	Lock lock = new ReentrantLock();//锁对象
	Condition condition = lock.newCondition();//线程通信对象，必须在锁上实例化对象
	public void loopTask() {
		lock.lock();
		try {
			while(!flag){//防止线程虚假唤醒
				try {
					condition.await();//线程等待
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			for(int i=1;i<=100;i++) {
				System.out.println("子线程执行："+i);
			}
			flag = false;
			condition.signal();//唤醒线程
		} finally {
			lock.unlock();
		}
	}
	public void mainTask() {
		lock.lock();
		try {
			while(flag){
				try {
					condition.await();
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			for(int i=1;i<=50;i++) {
				System.out.println("主线程执行："+i);
			}
			flag = true;
			condition.signal();
		} finally {
			lock.unlock();
		}
	}
}