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

看完上述內容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注億速云行業資訊頻道，感謝您對億速云的支持。