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 queue = 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() + "。。。 ,当前个数:" + 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(); 看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注创新互联行业资讯频道，感谢您对创新互联的支持。