notifyAll()唤醒线程时与什么有关

淡淡的烟草味﹌ 2022-08-21 00:24 133阅读 0赞

notifyAll()因某个特定锁调用时，只能等待这个锁的任务才会被唤醒，而**这个锁与底层锁有关**。

具体代码以及解释如下：

/**
     * notifyAll() 只能唤醒特定锁 wait()的线程 该特定锁与底层对象有关
     * 
     * @author he
     *
     */
    class Blocker {
    	// 将线程挂起
    	synchronized void waitingforCall() {
    		try {
    			while (!Thread.interrupted()) {
    				wait();
    				System.out.println("线程的hashCode: " + Thread.currentThread().hashCode());
    			}
    
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		}
    	}
    
    	// 唤醒单线程
    	synchronized void prod() {
    		notify();
    	}
    
    	// 唤醒所有线程
    	synchronized void prodAll() {
    		notifyAll();
    	}
    }
    
    class Task implements Runnable {
    	static Blocker b1;
    
    	public Task(Blocker b) {
    		b1 = b;
    	}
    
    	// 挂起线程
    	public synchronized void run() {
    		b1.waitingforCall();
    	}
    }
    
    class Task2 implements Runnable {
    	static Blocker b2;
    
    	public Task2(Blocker b) {
    		b2 = b;
    	}
    
    	// 挂起线程
    	public synchronized void run() {
    		b2.waitingforCall();
    	}
    }
    
    public class Test {
    	public static void main(String[] args) throws Exception {
    		ExecutorService eService = Executors.newCachedThreadPool();
    		// Blocker的两个不同实例，使用两个线程启动两个任务
    		Blocker b = new Blocker();
    		Blocker b2 = new Blocker();
    		eService.execute(new Task(b));
    		eService.execute(new Task2(b2));
    
    		/**
    		 * 结果：
    		 *  线程的hashCode: 2059770520 
    		 *  线程的hashCode: 2059770520 
    		 *  线程的hashCode: 2059770520 
    		 *  线程的hashCode: 2059770520 
    		 *  线程的hashCode: 2059770520
    		 *  	....
    		 *  
    		 *  原因：虽然在下方的代码中不停的交替调用Task中实例Blocker的prod()和prodAll()方法
    		 *  	 但是因为Task中的Blocker和Task2中的Blocker实例是不同的因此具有两个不同的对象锁
    		 *  	 所以每次唤醒时只能唤醒Task中的Blocker对象无法唤醒Task2中的Blocker对象，只有一个线程的hashCode
    		 *  
    		 *  
    		 *  如果将Task和Task2中传入相同的Blocker对象，则下方的代码能唤醒Task2中的Blocker对象
    		 * 
    		 *      eService.execute(new Task(b));
    		 *	eService.execute(new Task2(b));
    		 *	
    		 *  执行结果如下：线程的hashCode: 2059770520
    		 *	   线程的hashCode: 2059770520
    		 *		  线程的hashCode: 1824109660
    		 *				....
    		 *  	
    		 *  具有两个线程的 hashCode
    		 *  
    		 *  
    		 *  
    		 *  
    		 *  
    		 *  
    		 */
    
    		Timer t = new Timer();
    		t.schedule(new TimerTask() {
    			boolean pro = true;
    
    			@Override
    			public void run() {
    				// 交替使用Task.b1的prod()方法和prodAll()方法
    				if (pro) {
    					Task.b1.prod();
    					pro = false;
    				} else {
    					Task.b1.prodAll();
    					pro = true;
    				}
    			}
    		}, 400, 400);
    
    		TimeUnit.SECONDS.sleep(5);
    		t.cancel();
    		eService.shutdown();
    		System.exit(0);
    	}
    
    }