本例子实现了两个线程,每个线程输出1到100的数字。
第一个线程输出1-10,停止,通知第二个线程 输出1-10 第二个线程停止 通知第一个线程 输出11-20 ...
实现的要点是
在java中,每个对象都有个对象锁标志(object lock flag)与之想关联,当一个线程a调用对象的一段synchronized代码时,
它首先要获取与这个对象关联的对象锁标志,然后执行相应的代码,执行结束后,把这个对象锁标志返回给对象;因此,在线程a执行
synchronized代码期间,如果另一个线程b也要执行同一对象的一段synchronized代码时(不一定与线程a执行的相同),它将
要等到线程a执行完后,才能继续....
如何利用wait() notify() notifyall()?
在synchronized代码被执行期间,线程可以调用对象的wait()方法,释放对象锁标志,进入等待状态,并且可以调用notify()或者
notifyall()方法通知正在等待的其他线程。notify()通知等待队列中的第一个线程,notifyall()通知的是等待队列中的所有线程。
package com.chinajavalab.study.thread;
/**
* title: jasons's java projdect
* copyright: copyright (c) chinajavalab
* company: http://www.chinajavalab.com
* @author jason jason@chinajavalab.com
* @version 1.0
*/
import java.lang.runnable;
import java.lang.thread;
public class demothread implements runnable{
public demothread() {
testthread testthread1 = new testthread(this,"1");
testthread testthread2 = new testthread(this,"2");
testthread2.start();
testthread1.start();
}
public static void main(string[] args) {
demothread demothread1 = new demothread();
}
public void run(){
testthread t = (testthread) thread.currentthread();
try{
if (!t.getname().equalsignorecase("1")) {
synchronized(this) {
wait();
}
}
while(true){
system.out.println("@time in thread"+ t.getname()+ "="+ t.increasetime());
if(t.gettime()%10 == 0) {
synchronized(this) {
system.out.println("****************************************");
notify();
if ( t.gettime()==100 ) break;
wait();
}
}
}
}catch(exception e){e.printstacktrace();}
}
}
class testthread extends thread{
private int time = 0 ;
public testthread(runnable r,string name){
super(r,name);
}
public int gettime(){
return time;
}
public int increasetime (){
return ++time;
}
}
下载源程序
运行方法 (for windows):
javac -d . demothread.java
java -classpath .;%classpath% com.chinajavalab.study.thread.demothread
闽公网安备 35060202000074号