溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章給大家介紹java中的線程怎么實現等待與通知，內容非常詳細，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助。
關于等待/通知，要記住的關鍵點是：
必須從同步環境內調用wait()、notify()、notifyAll()方法。線程不能調用對象上等待或通知的方法，除非它擁有那個對象的鎖。
wait()、notify()、notifyAll()都是Object的實例方法。與每個對象具有鎖一樣，每個對象可以有一個線程列表，他們等待來自該信號（通知）。線程通過執行對象上的wait()方法獲得這個等待列表。從那時候起，它不再執行任何其他指令，直到調用對象的notify()方法為止。如果多個線程在同一個對象上等待，則將只選擇一個線程（不保證以何種順序）繼續執行。如果沒有線程等待，則不采取任何特殊操作。
示例代碼：
package threadwait;
public class ThreadA extends Thread{
public int num = 0;
public void run(){
synchronized (this){//在此類對象上實現同步，this指代當前對象
for(int i = 0 ; i < 3 ; ++i)
this.num+=i;
notifyAll();//通知所有在這個對象上等待的線程開始執行，在這里就是通知TestNotify主線程開始執行
}
}
public int getNum(){
return this.num;
}
}package threadwait;
public class TestNotify{
public static void main(String args[]){
ThreadA threada = new ThreadA();
threada.start();//threada線程有執行的資格，但是還沒有開始執行
synchronized(threada){
try{
threada.wait();//主線程等待threada線程執行結束才開始執行
//而且只有獲得了當前threada對象的鎖之后才能執行wait，就是說在同步域內才可以執行wait，執行wait后放棄對象鎖
}catch(InterruptedException e){
e.printStackTrace();
}
}
System.out.println(threada.getNum());
}
}同步可以是在class級別上的，synchronized(A.class)，也可以是在對象級別上的synchronized(this),可以是靜態同步方法，static synchronized ,靜態同步方法是在class級別上的，非靜態同步方法是在類對象級別上的，一個類對象只有一個鎖，只有獲得了該鎖才可以對他執行wait操作，后釋放掉該鎖。
更進一步的實例代碼如下：
package threadwait;
public class ThreadA extends Thread{
public int num = 0;
public void run(){
synchronized (this){//在此類對象上實現同步，this指代當前對象
for(int i = 0 ; i < 3 ; ++i)
this.num+=i;
try{
Thread.sleep(500);//如果ThreadB的三個示例線程在還沒有進入等待狀態之前就受到了notifyall的信號
//那將會發生嚴重后果，因為調用notifyall的線程只可以調用一次notifyall，那造成等待的線程將永遠等待下去
//所以在此處讓它睡一小會，讓其他線程有時間進入等待狀態。
//不然會收到
}catch(InterruptedException e){
e.printStackTrace();
}
notifyAll();//通知所有在這個對象上等待的線程開始執行，在這里就是通知TestNotify主線程開始執行
}
// notifyAll();
}
public int getNum(){
return this.num;
}
}package threadwait;
public class ThreadB extends Thread{
private ThreadA threada;
public ThreadB(ThreadA ta){
this.threada = ta;
}
public void run(){
System.out.println(Thread.currentThread().getName()+" is waitting.");
synchronized(threada){
try{
threada.wait();
}catch(InterruptedException e){
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+" "+this.threada.getNum());
}
}
}package threadwait;
public class TestNotify{
public static void main(String args[]){
ThreadA threada = new ThreadA();
new ThreadB(threada).start();
new ThreadB(threada).start();
new ThreadB(threada).start();
threada.start();
}
}關于java中的線程怎么實現等待與通知就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
