Java等待与唤醒机制的简单实现

Myth丶恋晨 2022-12-18 11:57 95阅读 0赞

**采取等待与唤醒机制目的：避免多个线程操作同一份数据时造成共享变量的争夺。**

创建设备类：

package proConModel;
    
    /**
     * 设备类
     * 
     * @author WanAkiko
     *
     */
    public class Machine {
    
    	String deviceName; // 设备名称
    	String deviceType; // 设备型号
    	boolean flag = false; // 设备状态，是否可用
    
    }

创建生产者类

package proConModel;
    
    /**
     * 生产者
     * 
     * @author WanAkiko 生产者类与设备类间的关系：通信(互斥)
     * 
     */
    public class Producer extends Thread {
    
    	private Machine mac; // 声明成员设备类变量
    
    	// 使用有参构造方法为设备类变量赋值
    	public Producer(Machine mac) {
    		this.mac = mac;
    	}
    
    	// 设置线程任务：生产设备
    	@Override
    	public void run() {
    		int count = 0; // 根据奇偶性的不同生产不同类型的设备
    		while (true) { // 无限次生产设备
    			synchronized (mac) { // 确保等待与唤醒不同时执行
    				if (mac.flag == true) { // 判断设备状态(可用)
    					try {
    						mac.wait(); // 调用锁对象的wait()让线程进入等待状态
    					} catch (InterruptedException e) {
    						e.printStackTrace();
    					}
    				}
    				if (count % 2 == 0) { // 根据奇偶性的不同生产不同类型的设备
    					mac.deviceName = "iPhone7 Plus";
    					mac.deviceType = "ios7";
    				} else {
    					mac.deviceName = "iPhone8 Plus ";
    					mac.deviceType = "ios8";
    				}
    				count++; // 择型器自增
    				System.out.println("生产者：正在生产系统为" + mac.deviceType + "的" + mac.deviceName + "！");
    				try {
    					Thread.sleep(2000); // 线程休眠2秒，模拟生产用时
    				} catch (InterruptedException e) {
    					e.printStackTrace();
    				}
    				mac.flag = true; // 修改设备状态
    				mac.notify(); // 唤醒消费者类购买已生产的设备
    				System.out.println(mac.deviceType + "系列" + mac.deviceName + "生产完毕，可供销售！");
    			}
    		}
    	}
    
    }

创建消费者类：

package proConModel;
    
    /**
     * 消费者
     * 
     * @author WanAkiko
     *
     */
    public class Consumer extends Thread {
    
    	private Machine mac; // 声明成员设备类变量
    
    	// 调用消费者类的有参构造方法
    	public Consumer(Machine mac) {
    		this.mac = mac;
    	}
    
    	// 设置线程任务：购买设备
    	@Override
    	public void run() {
    		while (true) {
    			synchronized (mac) {
    				if (mac.flag == false) { // 判断设备状态
    					try {
    						mac.wait();
    					} catch (InterruptedException e) {
    						e.printStackTrace();
    					}
    				}
    				System.out.println("消费者：正在购买" + mac.deviceType + "系统的" + mac.deviceName);
    				mac.flag = false; // 修改设备状态
    				mac.notify(); // 消费者线程唤醒生产者线程，使之开始生产设备
    				System.out.println(mac.deviceType + "系统的" + mac.deviceName + "设备已被抢购一空！");
    				System.out.println("--------------------------------------------------------------------------------");
    			}
    		}
    	}
    
    }

创建测试类：

package proConModel;
    
    /**
     * 测试类
     * 
     * @author WanAkiko
     *
     */
    public class Client {
    
    	public static void main(String[] args) {
    
    		Machine mac = new Machine(); // 创建设备对象
    		new Producer(mac).start(); // 生产者生产设备
    		new Consumer(mac).start(); // 消费者购买设备
    
    	}
    
    }

运行示例：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTY1Mzkz_size_16_color_FFFFFF_t_70_pic_center]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTY1Mzkz_size_16_color_FFFFFF_t_70_pic_center]: /images/20221122/5ae197093b47462692d1dbdcbe9c509a.png