在JAVA中，是沒有類似于PV操作、進程互斥等相干的方法的。JAVA的進程同步是通過synchronized()來實現的，需要說明的是，JAVA的synchronized()方法類似于操作系統概念中的互斥內存塊，在JAVA中的Object類型中，都是帶有1個內存鎖的，在有線程獲得該內存鎖后，其它線程沒法訪問該內存，從而實現JAVA中簡單的同步、互斥操作。明白這個原理，就可以理解為何synchronized(this)與synchronized(static XXX)的區分了，synchronized就是針對內存區塊申請內存鎖，this關鍵字代表類的1個對象，所以其內存鎖是針對相同對象的互斥操作，而static成員屬于類專有，其內存空間為該類所有成員共有，這就致使synchronized()對static成員加鎖，相當于對類加鎖，也就是在該類的所有成員間實現互斥，在同1時間只有1個線程可訪問該類的實例。如果只是簡單的想要實現在JAVA中的線程互斥，明白這些基本就已夠了。但如果需要在線程間相互喚醒的話就需要借助Object.wait(), Object.nofity()了。
Obj.wait()，與Obj.notify()必須要與synchronized(Obj)1起使用，也就是wait,與notify是針對已獲得了Obj鎖進行操作，從語法角度來講就是Obj.wait(),Obj.notify必須在synchronized(Obj){…}語句塊內。從功能上來講wait就是說線程在獲得對象鎖后，主動釋放對象鎖，同時本線程休眠。直到有其它線程調用對象的notify()喚醒該線程，才能繼續獲得對象鎖，并繼續履行。相應的notify()就是對對象鎖的喚醒操作。但有1點需要注意的是notify()調用后，其實不是馬上就釋放對象鎖的，而是在相應的synchronized(){}語句塊履行結束，自動釋放鎖后，JVM會在wait()對象鎖的線程中隨機選取1線程，賦予其對象鎖，喚醒線程，繼續履行。這樣就提供了在線程間同步、喚醒的操作。Thread.sleep()與Object.wait()2者都可以暫停當前線程，釋放CPU控制權，主要的區分在于Object.wait()在釋放CPU同時，釋放了對象鎖的控制。
單單在概念上理解清楚了還不夠，需要在實際的例子中進行測試才能更好的理解。對Object.wait()，Object.notify()的利用最經典的例子，應當是3線程打印ABC的問題了吧，這是1道比較經典的面試題，題目要求以下：
建立3個線程，A線程打印10次A，B線程打印10次B,C線程打印10次C，要求線程同時運行，交替打印10次ABC。這個問題用Object的wait()，notify()就能夠很方便的解決。代碼以下：
[java] view plain copy
public class MyThreadPrinter2 implements Runnable {
private String name;
private Object prev;
private Object self;
private MyThreadPrinter2(String name, Object prev, Object self) {
this.name = name;
this.prev = prev;
this.self = self;
}
@Override
public void run() {
int count = 10;
while (count > 0) {
synchronized (prev) {
synchronized (self) {
System.out.print(name);
count--;
self.notify();
}
try {
prev.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
public static void main(String[] args) throws Exception {
Object a = new Object();
Object b = new Object();
Object c = new Object();
MyThreadPrinter2 pa = new MyThreadPrinter2("A", c, a);
MyThreadPrinter2 pb = new MyThreadPrinter2("B", a, b);
MyThreadPrinter2 pc = new MyThreadPrinter2("C", b, c);
new Thread(pa).start();
new Thread(pb).start();
new Thread(pc).start();
}
} 先來解釋1下其整體思路，從大的方向上來說，該問題為3線程間的同步喚醒操作，主要的目的就是ThreadA->ThreadB->ThreadC->ThreadA循環履行3個線程。為了控制線程履行的順序，那末就必須要肯定喚醒、等待的順序，所以每個線程必須同時持有兩個對象鎖，才能繼續履行。1個對象鎖是prev，就是前1個線程所持有的對象鎖。還有1個就是本身對象鎖。主要的思想就是，為了控制履行的順序，必須要先持有prev鎖，也就前1個線程要釋放本身對象鎖，再去申請本身對象鎖，二者兼備時打印，以后首先調用self.notify()釋放本身對象鎖，喚醒下1個等待線程，再調用prev.wait()釋放prev對象鎖，終止當前線程，等待循環結束后再次被喚醒。運行上述代碼，可以發現3個線程循環打印ABC，共10次。程序運行的主要進程就是A線程最早運行，持有C,A對象鎖，后釋放A,C鎖，喚醒B。線程B等待A鎖，再申請B鎖，后打印B，再釋放B，A鎖，喚醒C，線程C等待B鎖，再申請C鎖，后打印C，再釋放C,B鎖，喚醒A。看起來仿佛沒甚么問題，但如果你仔細想1下，就會發現有問題，就是初始條件，3個線程依照A,B,C的順序來啟動，依照前面的思考，A喚醒B，B喚醒C，C再喚醒A。但是這類假定依賴于JVM中線程調度、履行的順序。具體來講就是，在main主線程啟動ThreadA后，需要在ThreadA履行完，在prev.wait()等待時，再切回線程啟動ThreadB，ThreadB履行完，在prev.wait()等待時，再切回主線程，啟動ThreadC，只有JVM依照這個線程運行順序履行，才能保證輸出的結果是正確的。而這依賴于JVM的具體實現。斟酌1種情況，以下：如果主線程在啟動A后，履行A，進程中又切回主線程，啟動了ThreadB,ThreadC，以后，由于A線程還沒有釋放self.notify，也就是B需要在synchronized(prev)處等待，而這時候C卻調用synchronized(prev)獲得了對b的對象鎖。這樣，在A調用完后，同時ThreadB獲得了prev也就是a的對象鎖，ThreadC的履行條件就已滿足了，會打印C，以后釋放c,及b的對象鎖，這時候ThreadB具有了運行條件，會打印B，也就是循環變成了ACBACB了。這類情況，可以通過在run中主動釋放CPU，來進行摹擬。代碼以下：
public void run() {
int count = 10;
while (count > 0) {
synchronized (prev) {
synchronized (self) {
System.out.print(name);
count--;
try{
Thread.sleep(1);
}
catch (InterruptedException e){
e.printStackTrace();
}
self.notify();
}
try {
prev.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
} 運行后的打印結果就變成了ACBACB了。為了不這類與JVM調度有關的不肯定性。需要讓A,B,C3個線程以肯定的順序啟動，終究代碼以下：
public class MyThreadPrinter2 implements Runnable {
private String name;
private Object prev;
private Object self;
private MyThreadPrinter2(String name, Object prev, Object self) {
this.name = name;
this.prev = prev;
this.self = self;
}
@Override
public void run() {
int count = 10;
while (count > 0) {
synchronized (prev) {
synchronized (self) {
System.out.print(name);
count--;
try{
Thread.sleep(1);
}
catch (InterruptedException e){
e.printStackTrace();
}
self.notify();
}
try {
prev.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
public static void main(String[] args) throws Exception {
Object a = new Object();
Object b = new Object();
Object c = new Object();
MyThreadPrinter2 pa = new MyThreadPrinter2("A", c, a);
MyThreadPrinter2 pb = new MyThreadPrinter2("B", a, b);
MyThreadPrinter2 pc = new MyThreadPrinter2("C", b, c);
new Thread(pa).start();
Thread.sleep(10);
new Thread(pb).start();
Thread.sleep(10);
new Thread(pc).start();
Thread.sleep(10);
}
}這樣才可以完善的解決該問題。通過這個例子也是想說明1下，很多理論、概念如Obj.wait(),Obj.notify()等，理解起來，比較簡單，但是在實際的利用當中，這里卻是常常出現問題的地方。需要更加深入的理解。并在解決問題的進程中不斷加深對概念的掌握
轉于http://blog.csdn.net/zyplus
程序員人生，我編程，我富裕，記住wfuyu網，php教程，php學習，php手冊，CMS模版制作
聲明：本站大部分內容是作者原創，少部分收集于互聯網供大家一起學習，原版權很多不明，如有侵權請聯系本站，謝謝！
粵ICP備14040726號-1?? 2015-2020 程序員人生 版權所有
