多線程wait和notify的理解
對多線程編程里wait() notify()的精確論述:這一對方法直接隸屬于 Object 類,也就是說,所有對象都擁有這一對方法。
初看起來這十分不可思議,但是實際上卻是很自然的,因為這一對方法阻塞時要釋放占用的鎖,而鎖是任何對象都具有的,調用任意對象的 wait() 方法導致線程阻塞,并且該對象上的鎖被釋放。而調用 任意對象的notify()方法則導致因調用該對象的 wait() 方法而阻塞的線程中隨機選擇的一個解除阻塞(但要等到獲得鎖后才真正可執(zhí)行)。
其次,前面敘述的所有方法都可在任何位置調用,但是這一對方法卻必須在 synchronized 方法或塊中調用,理由也很簡單,只有在synchronized 方法或塊中當前線程才占有鎖,才有鎖可以釋放。同樣的道理,調用這一對方法的對象上的鎖必須為當前線程所擁有,這樣才有鎖可以釋放。因此,這一對方法調用 必須放置在這樣的 synchronized 方法或塊中,該方法或塊的上鎖對象就是調用這一對方法的對象。若不滿足這一條件,則程序雖然仍能編譯,但在運行時會出現 IllegalMonitorStateException 異常
/**
* 這是5個工人干活的例子,因為工人的效率不一樣,效率高的先完成任務,
*/
public static void main(String[] args) throws InterruptedException {
Resource r = new Resource(4);
ThreadGroup tg = new ThreadGroup("GT");
new Thread(tg, new Worker(r,8)).start();
new Thread(tg, new Worker(r,12)).start();
new Thread(tg, new Worker(r,22)).start();
new Thread(tg, new Worker(r,16)).start();
new Thread(tg, new Worker(r,20)).start();
new Thread(tg, new Manager()).start();
}
}
public class Worker implements Runnable {
private Resource r;
/**
* the mission
*/
private int efficiency;
public Worker(Resource r,int efficiency){
this.r = r;
this.efficiency = efficiency;
}
public void run() {
int i = 0;
while(true){
System.out.println(Thread.currentThread()+" is working");
i ++;
if(i == efficiency){
i = 0;
r.waitForAll();
}
try {
Thread.currentThread().sleep(1000);
}
catch (InterruptedException ex) {
ex.printStackTrace();
}
}
}
}
public class Worker implements Runnable {
private Resource r;
/**
* the mission
*/
private int efficiency;
public Worker(Resource r,int efficiency){
this.r = r;
this.efficiency = efficiency;
}
public void run() {
int i = 0;
while(true){
System.out.println(Thread.currentThread()+" is working");
i ++;
if(i == efficiency){
i = 0;
r.waitForAll();
}
try {
Thread.currentThread().sleep(1000);
}
catch (InterruptedException ex) {
ex.printStackTrace();
}
}
}
}