線程基礎---wait(),notify的應用一例
作者:jdeveloper
本例子實現了兩個線程,每個線程輸出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 jdeveloper.study;
/**
* Title: Jdeveloper's Java Projdect
* Description: n/a
* Copyright: Copyright (c) 2001
* Company: soho http://www.ChinaJavaWorld.com
* @author [email protected]
* @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% jdeveloper.study.DemoThread