消息队列处理，常用于队列任务的处理

package com.langtaosha.queuetest; import java.util.Random; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; //测试 public class MainCmd { public static void main(String[] args) { //开启三个线程来处理逻辑 ExecutorService service = Executors.newFixedThreadPool(3); //取出消息模拟发送 service.execute(new Runnable() { public void run() { while (true) { Message message = MessageQueue.get(); if (message != null) System.out.println("时间：" + message.getMillis() + ";内容：" + message.getContent()); try { Thread.sleep(20); } catch (Exception e) {} } } }); //向队列中放入消息,模拟三个客户端 service.execute(new Runnable() { public void run() { while (true) { Message message = new Message(); message.setContent("消息内容"); MessageQueue.add(message); try { Thread.sleep(new Random().nextInt(1000)); } catch (Exception e) {} } } }); service.execute(new Runnable() { public void run() { while (true) { Message message = new Message(); message.setContent("消息内容"); MessageQueue.add(message); try { Thread.sleep(new Random().nextInt(300)); } catch (Exception e) {} } } }); service.execute(new Runnable() { public void run() { while (true) { Message message = new Message(); message.setContent("消息内容"); MessageQueue.add(message); try { Thread.sleep(new Random().nextInt(50)); } catch (Exception e) {} } } }); } }