码迷,mamicode.com
首页 > 编程语言 > 详细

java 线程之间的协作 wait()与notifyAll()

时间:2014-10-07 12:12:43      阅读:269      评论:0      收藏:0      [点我收藏+]

标签:java   thread   线程   

bubuko.com,布布扣bubuko.com,布布扣

              bubuko.com,布布扣

package org.rui.thread.block;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

// wax蜡    电气自动方式
public class WaxOMatic {

	public static void main(String[] args) throws InterruptedException {
		Car car = new Car();
		ExecutorService exec = Executors.newCachedThreadPool();
		exec.execute(new WaxOff(car));
		exec.execute(new WaxOn(car));
		TimeUnit.SECONDS.sleep(5);
		exec.shutdownNow();// 中断所有任务
		// shutdownNow 试图停止所有正在执行的活动任务,暂停处理正在等待的任务,并返回等待执行的任务列表
	}
}

class Car {
	//表示 抛光 、上蜡的处理状态
	private boolean waxOn = false;

	// 上蜡
	public synchronized void waxed() {
		waxOn = true;// ready to buff
		notifyAll();
	}

	// 抛光
	public synchronized void buffed() {
		waxOn = false;// ready to another coat of wax
		notifyAll();
	}

	// wait 上蜡
	public synchronized void waitForWaxing() throws InterruptedException {
		while (waxOn == false) {
			wait();//挂起这个任务
		}
	}

	// wait 抛光
	public synchronized void waitForBuffing() throws InterruptedException {
		while (waxOn == true) {
			wait();//挂起这个任务
		}
	}
}

class WaxOn implements Runnable {
	private Car car;

	public WaxOn(Car c) {
		car = c;
	}

	@Override
	public void run() {
		try {
			while (!Thread.interrupted()) {
				System.out.println("wax on!");
				TimeUnit.MILLISECONDS.sleep(200);
				car.waxed();// 上蜡  
				car.waitForBuffing();//等 抛光
			}
		} catch (InterruptedException e) {
			System.out.println("通过中断退出");
			// e.printStackTrace();
		}
		System.out.println("ending Wax on task");
	}

}

// /////////////////////

class WaxOff implements Runnable {
	private Car car;

	public WaxOff(Car c) {
		car = c;
	}

	@Override
	public void run() {
		try {
			while (!Thread.interrupted()) {
				car.waitForWaxing();//等 吐蜡
				System.out.println("wax off!");
				TimeUnit.MILLISECONDS.sleep(200);
				car.buffed();//抛光

			}
		} catch (InterruptedException e) {
			System.out.println("通过中断退出");
			// e.printStackTrace();
		}
		System.out.println("ending Wax Off task");
	}

}

/*output:(95% match) 
wax on!
wax off!
wax on!
wax off!
wax on!
wax off!
wax on!
wax off!
wax on!
wax off!
wax on!
wax off!
wax on!
wax off!
wax on!
wax off!
wax on!
通过中断退出
ending Wax on task
通过中断退出
ending Wax Off task
*/

bubuko.com,布布扣


bubuko.com,布布扣

java 线程之间的协作 wait()与notifyAll()

标签:java   thread   线程   

原文地址:http://blog.csdn.net/liangrui1988/article/details/39852535

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!