Java基础之线程间等待唤醒机制

谁借莪１个温暖的怀抱￠ 2022-11-30 05:46 320阅读 0赞

/*
    等待/唤醒机制。 
    
    涉及的方法：
    
    1，wait(): 让线程处于冻结状态，被wait的线程会被存储到线程池中。
    2，notify():唤醒线程池中一个线程(任意).
    3，notifyAll():唤醒线程池中的所有线程。
    
    这些方法都必须定义在同步中。
    因为这些方法是用于操作线程状态的方法。
    必须要明确到底操作的是哪个锁上的线程。
    
    
    为什么操作线程的方法wait notify notifyAll定义在了Object类中？ 
    
    因为这些方法是监视器的方法。监视器其实就是锁。
    锁可以是任意的对象，任意的对象调用的方式一定定义在Object类中。
    
    */
    //资源
    class Resource
    {
        
    	String name;
    	String sex;
    	boolean flag = false;
    }
    
    
    //输入
    class Input implements Runnable
    {
        
    	Resource r ;
    //	Object obj = new Object();
    	Input(Resource r)
    	{
        
    		this.r = r;
    	}
    	public void run()
    	{
        
    		int x = 0;
    		while(true)
    		{
        
    			synchronized(r)
    			{
        
    				if(r.flag)
    					try{
        r.wait();}catch(InterruptedException e){
        }
    				if(x==0)
    				{
        
    					r.name = "mike";
    					r.sex = "nan";
    				}
    				else
    				{
        
    					r.name = "丽丽";
    					r.sex = "女女女女女女";
    				}
    				r.flag = true;
    				r.notify();
    			}
    			x = (x+1)%2;
    
    		}
    	}
    }
    //输出
    class Output implements Runnable
    {
        
    
    	Resource r;
    //	Object obj = new Object();
    	Output(Resource r)
    	{
        
    		this.r = r;
    	}
    
    	public void run()
    	{
        
    		while(true)
    		{
        
    			synchronized(r)
    			{
        
    				if(!r.flag)
    					try{
        r.wait();}catch(InterruptedException e){
        }
    				System.out.println(r.name+"....."+r.sex);
    				r.flag = false;
    				r.notify();
    			}
    		}
    	}
    }
    
    
    
    class  ResourceDemo2
    {
        
    	public static void main(String[] args) 
    	{
        
    		//创建资源。
    		Resource r = new Resource();
    		//创建任务。
    		Input in = new Input(r);
    		Output out = new Output(r);
    		//创建线程，执行路径。
    		Thread t1 = new Thread(in);
    		Thread t2 = new Thread(out);
    		//开启线程
    		t1.start();
    		t2.start();
    	}
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDg1MzY2OQ_size_16_color_FFFFFF_t_70_pic_center_pic_center]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDg1MzY2OQ_size_16_color_FFFFFF_t_70_pic_center_pic_center]: /images/20221124/ce1e471fc4764ed4a1d8609964fce102.png