大橙子网站建设,新征程启航
为企业提供网站建设、域名注册、服务器等服务
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 { 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() + "。。。 ,当前个数:" + 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();
看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注创新互联行业资讯频道,感谢您对创新互联的支持。