Java中Message類和Queue類如何使用,很多新手對此不是很清楚,為了幫助大家解決這個難題,下面小編將為大家詳細講解,有這方面需求的人可以來學習下,希望你能有所收獲。
成都創(chuàng)新互聯(lián)專注于房縣企業(yè)網(wǎng)站建設,成都響應式網(wǎng)站建設公司,商城網(wǎng)站建設。房縣網(wǎng)站建設公司,為房縣等地區(qū)提供建站服務。全流程按需定制網(wǎng)站,專業(yè)設計,全程項目跟蹤,成都創(chuàng)新互聯(lián)專業(yè)和態(tài)度為您提供的服務
Message類
package com.example.test; public class Message { public static int id; public String content; public String getContent() { return content; } public void setContent(String content) { this.content = content; } public int getId() { return id; } public void setId(int id) { Message.id = id; } }
Queue類
package com.example.test; import java.util.ArrayList; import java.util.List; public class Queue { Listqueue = new ArrayList (); /** 隊列中message對象的***值,默認為5 */ int maxMessageNum = 5; public synchronized void produce(Message message) { this.notifyAll(); while (queue.size() == maxMessageNum) { System.out.println(Thread.currentThread().getName() + " 隊列滿!等待中。。。"); try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } queue.add(message); System.out.println(Thread.currentThread().getName() + "正在生產" + message.getContent() + "。。。 ,當前個數(shù):" + getCount()); } public synchronized void consume() { this.notifyAll(); while (queue.size() == 0) { System.out.println(Thread.currentThread().getName() + " 隊列空!等待中。。。"); try { System.out.println("begin!"); wait(); System.out.println("end!"); } catch (InterruptedException e) { e.printStackTrace(); } } Message message = queue.get(0); queue.remove(0); System.out.println(Thread.currentThread().getName() + "正在消費" + message.getContent() + "。。。 ,當前個數(shù): " + getCount()); } public synchronized int getCount() { return queue.size();
看完上述內容是否對您有幫助呢?如果還想對相關知識有進一步的了解或閱讀更多相關文章,請關注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝您對創(chuàng)新互聯(lián)的支持。