Java中Message类和Queue类如何使用

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();

看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注亿速云行业资讯频道，感谢您对亿速云的支持。