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




  • 相关阅读:
    应用量化时代 | 微服务架构的服务治理之路
    API网关——Kong实践分享
    容器云未来:Kubernetes、Istio 和 Knative
    微服务网关实战——Spring Cloud Gateway
    服务迁移之路 | Spring Cloud向Service Mesh转变
    基于事件驱动机制,在Service Mesh中进行消息传递的探讨
    MSMQ 和 MQTT
    MQTT和WebSocket
    NetCore WebSocket 即时通讯示例
    .NET 即时通信,WebSocket服务端实例
  • 原文地址:https://www.cnblogs.com/liguangsunls/p/6748888.html
Copyright © 2011-2022 走看看