這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)?lái)有關(guān)如何通過(guò)一個(gè)例子來(lái)描述線程wait和notify,文章內(nèi)容豐富且以專(zhuān)業(yè)的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。
創(chuàng)新互聯(lián)是一家專(zhuān)業(yè)提供仙桃企業(yè)網(wǎng)站建設(shè),專(zhuān)注與網(wǎng)站設(shè)計(jì)、網(wǎng)站制作、H5建站、小程序制作等業(yè)務(wù)。10年已為仙桃眾多企業(yè)、政府機(jī)構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專(zhuān)業(yè)網(wǎng)站制作公司優(yōu)惠進(jìn)行中。
場(chǎng)景:一個(gè)類(lèi)中,一個(gè)是往容器中添加元素的方法,一個(gè)是返回容器大小的方法,現(xiàn)在又兩個(gè)線程,A線程調(diào)用添加方法,B線程調(diào)用返回容器大小方法,當(dāng)大小為5的時(shí)候,B線程提示并結(jié)束。
代碼可直接復(fù)制,運(yùn)行:
public class UseWaitAndNotify { volatile List list = new ArrayList();//這里為什么使用volatile,請(qǐng)看:https://my.oschina.net/u/4049911/blog/3121294 public void add(Object o) { list.add(o); } public int size() { return list.size(); } public void useWaitAndNotify() { new Thread(new Runnable() { @Override public void run() { synchronized (this) { System.out.println("size方法開(kāi)始"); /** * 這里必須得是不等于5,因?yàn)閯傞_(kāi)始肯定不等于5,然后才會(huì)進(jìn)這個(gè)方法,執(zhí)行wait方法,這個(gè)線程就會(huì)在wait那等著。 * 然后cpu執(zhí)行另一個(gè)方法,當(dāng)另一個(gè)方法執(zhí)行等于5是,使用notify喚醒等待的線程(等待同一個(gè)鎖的線程)。 * 然后從wait方法開(kāi)始往下執(zhí)行,到結(jié)束。 */ if(list.size()!=5) { try { wait(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } System.out.println("size方法結(jié)束"); } } }).start(); synchronized (this) { System.out.println("add方法開(kāi)始"); for(int i=0;i<10;i++) { /** *當(dāng)加入元素==5時(shí),當(dāng)前線程就應(yīng)該停止,讓出cpu,讓cpu去執(zhí)行其他線程。 *那讓線程讓出cpu的方法有哪些呢: *wait讓出線程,釋放鎖 *yield 讓出cpu,但不會(huì)釋放鎖 *join 插入其他線程,線程同步作用,在被調(diào)用線程未結(jié)束前,當(dāng)前線程將一直阻塞在join處 * *我們使用wait * */ list.add(new Object()); if(i==4) { /** * 這里為什么使用notify后,又使用wait呢,就是上面這個(gè)方法的意思,使用notify,當(dāng)前線程是不會(huì)釋放鎖的,所以即使喚醒了其他 * 線程,其他線程拿不到鎖,也執(zhí)行不了。 * 也就是說(shuō)如果下面不使用wait,當(dāng)list等于5的時(shí)候,另一個(gè)線程拿不到鎖,執(zhí)行不了,只有當(dāng)前線程釋放鎖,另一個(gè)線程才會(huì)拿到鎖執(zhí)行, * 也就是說(shuō)當(dāng)list的size等于10的時(shí)候,另一個(gè)線程才會(huì)停止 */ this.notify(); try { this.wait(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } System.out.println("add方法結(jié)束"); } } } @Test public void test() { //使用wait和notify實(shí)現(xiàn) useWaitAndNotify(); } }
因?yàn)閣ait和notify只能在鎖中使用,所以需要加上synchronized鎖
上述就是小編為大家分享的如何通過(guò)一個(gè)例子來(lái)描述線程wait和notify了,如果剛好有類(lèi)似的疑惑,不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí),歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。