zoukankan      html  css  js  c++  java
  • java 线程之间的协作 wait()与notifyAll()

                  

    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
    */
    




  • 相关阅读:
    支付宝生活号内置浏览器长按保存二维码
    Web前端发展史
    ES6语法
    Java多线程
    Java基础知识
    静态库和动态库的使用
    Gcc的使用
    Vim的使用
    力扣345. 反转字符串中的元音字母
    力扣605. 种花问题
  • 原文地址:https://www.cnblogs.com/liguangsunls/p/6748888.html
Copyright © 2011-2022 走看看