Java中Message类和Queue类如何使用，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。
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 { List<Message> queue = new ArrayList<Message>(); /** 队列中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() + "。。。 ,当前个数:" + 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() + "。。。 ,当前个数: " + getCount()); } public synchronized int getCount() { return queue.size();
看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注本站行业资讯频道，感谢您对本站的支持。
