java并发(一)wait,notify的使用

Java是第一个内置对多线程支持的主流编程语言。在Java5以前,对多线程的支持主要是经过对块结构的同步实现的(synchronized配合wait,notify,notifyAll),Java5引入了java.util.concurrent包,提供了对多线程编程的更高层的支持。 java

在Java中,除了int等基本类型以外,一切皆为对象。synchronized关键字以及Object类中的wait,notify和notifyAll方法为咱们编写多线程程序提供了原始的支持。 算法

例如: 编程


public class A {
	public synchronized void fun() {
		...
	}
}

在调用方法fun以前,调用该方法的执行线程必需要先得到类A的实例(a)的对象锁。上面的方法fun在功能上等同于: 多线程

public void fun() {
	synchronized(this) {
		...
	}
}
在执行fun以前,要获取a的对象锁,在方法fun返回以前,要释放a的对象锁。

一般可使用synchronized和notify,notifyAll以及wait方法来实现线程之间的数据传递及控制。对于对象obj来讲: 编程语言

  • obj.wait():该方法的调用,使得调用该方法的执行线程(T1)放弃obj的对象锁并阻塞,直到别的线程调用了obj的notifyAll方法、或者别的线程调用了obj的notify方法且JVM选择唤醒(T1),被唤醒的线程(T1)依旧阻塞在wait方法中,与其它的线程一块儿争夺obj的对象锁,直到它再次得到了obj的对象锁以后,才能从wait方法中返回。(除了notify方法,wait还有带有时间参数的版本,在等待了超过所设时间以后,T1线程同样会被唤醒,进入到争夺obj对象锁的行列;另外中断能够直接跳出wait方法)
  • obj.notify():该方法的调用,会从全部正在等待obj对象锁的线程中,唤醒其中的一个(选择算法依赖于不一样实现),被唤醒的线程此时加入到了obj对象锁的争夺之中,然而该notify方法的执行线程此时并未释放obj的对象锁,而是离开synchronized代码块时释放。所以在notify方法以后,synchronized代码块结束以前,全部其余被唤醒的,等待obj对象锁的线程依旧被阻塞。
  • obj.notifyAll():与notify的区别是,该方法会唤醒全部正在等待obj对象锁的线程。(不过同一时刻,也只有一个线程能够拥有obj的对象锁)

要注意的是,wai,notify以及notifyAll方法的调用必须在相应的synchronized代码块之中。例如: ide


synchronized(obj) {
	while(xxx) {
		obj.wait();
	}
	...
}

下面写个小例子,来讲明wait方法返回以前要从新得到对象锁,以及notify方法执行以后并不当即释放对象锁。 this

public class MThread implements Runnable {
	public synchronized void assign() {
		this.notifyAll();
		System.err.println("out of notifyAll");
		while(true){}
	}
	
	public synchronized void await() throws InterruptedException {
		this.wait(5000);
		System.err.println("out of wait");
	}

	@Override
	public void run() {
			try {
				await();
			} catch (InterruptedException e) {
			}
	}

}


public class Main {
	public static void main(String[] args) {
		MThread mThread = new MThread();
		Thread thread = new Thread(mThread);
		thread.start();
		
		try {
			Thread.sleep(1000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		mThread.assign();
	}
}
主线程中,先建立子线程,并启动,主线程sleep一秒钟是为了让子线程中的this.wait(5000)获得执行,而wait(5000)又保证在五秒钟结束以前,主线程中的mThread.assign()方法获得调用,进而调用子线程的notifyAll方法,来唤醒wait方法。从执行结果中能够看到“out of notifyAll”的输出,却始终看不到“out of wait”,这说明notifyAll方法执行完成,而wait方法并未返回。一个合理的解释就是wait还在等待mThread的对象锁,而notifyAll执行完成后也并未当即释放mThread的对象锁,sun的官方文档的说明也是如此。

十点半了,哎,第一次发博客,不知如何,有点小忐忑 spa

相关文章
相关标签/搜索