小編給大家分享一下java多線程wait()和notify()如何使用,希望大家閱讀完這篇文章之后都有所收獲,下面讓我們一起去探討吧!
創(chuàng)新互聯(lián)服務(wù)項目包括武夷山網(wǎng)站建設(shè)、武夷山網(wǎng)站制作、武夷山網(wǎng)頁制作以及武夷山網(wǎng)絡(luò)營銷策劃等。多年來,我們專注于互聯(lián)網(wǎng)行業(yè),利用自身積累的技術(shù)優(yōu)勢、行業(yè)經(jīng)驗、深度合作伙伴關(guān)系等,向廣大中小型企業(yè)、政府機構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案,武夷山網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟效益。目前,我們服務(wù)的客戶以成都為中心已經(jīng)輻射到武夷山省份的部分城市,未來相信會繼續(xù)擴大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任!注:wait()和notify()應(yīng)當(dāng)用在synchronized內(nèi) package com.test; import java.util.ArrayList; public class ThreadWaitTeste { public static void main(String[] args) { ArrayListar = new ArrayList (); Product p = new Product(ar); Consumer c = new Consumer(ar); Thread t1 = new Thread(p); Thread t2 = new Thread(c); t1.start(); t2.start(); } } class Product implements Runnable{ ArrayList array; public Product(ArrayList array){ this.array= array; } public void run() { while (true){ synchronized(array){ if(this.array.size()<5){ this.array.add("test!"); this.array.add("test!"); this.array.add("test!"); this.array.add("test!"); System.out.println("Product size : "+array.size()); }else{ System.out.println("Product wait size : "+array.size()+"數(shù)量少于5,等待......"); try { array.wait(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } } } } class Consumer implements Runnable{ ArrayList array; public Consumer(ArrayList array){ this.array= array; } public void run() { while(true){ synchronized(array){ if(this.array.size()>=5){ this.array.remove(1); System.out.println("Consumer size : "+array.size()); }else{ try { array.notifyAll(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } } } } }
看完了這篇文章,相信你對“java多線程wait()和notify()如何使用”有了一定的了解,如果想了解更多相關(guān)知識,歡迎關(guān)注創(chuàng)新互聯(lián)-成都網(wǎng)站建設(shè)公司行業(yè)資訊頻道,感謝各位的閱讀!