Java框架中使用并发队列和阻塞队列进行消息处理

import java.util.concurrent.ConcurrentLinkedQueue;

public class MessageQueue {

  private final ConcurrentLinkedQueue<String> messages = new ConcurrentLinkedQueue<>();

  public void addMessage(String message) {
    messages.add(message);
  }

  public String getMessage() {
    return messages.poll();
  }
}

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;

public class MessageConsumer {

  private final MessageQueue queue;

  public MessageConsumer(MessageQueue queue) {
    this.queue = queue;
  }

  public void consumeMessages() {
    ExecutorService executor = Executors.newFixedThreadPool(1, new ThreadFactory() {
      @Override
      public Thread newThread(Runnable r) {
        return new Thread(r, "MessageConsumer");
      }
    });

    executor.submit(() -> {
      while (true) {
        String message = queue.getMessage();
        if (message != null) {
          // 处理消息
          System.out.println("Received message: " + message);
        }
      }
    });
  }
}