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