public class ThreadMQ {/*** Broker*/private static LinkedBlockingDeque<JSONObject> broker = new LinkedBlockingDeque<JSONObject>();public static void main(String[] args) {// 創建生產者線程Thread producer = new Thread(new Runnable() {@Overridepublic void run() {while (true) {try {Thread.sleep(1000);JSONObject data = new JSONObject();data.put("phone", "18611111111");broker.offer(data);} catch (Exception e) {}}}}, "生產者");producer.start();Thread consumer = new Thread(new Runnable() {@Overridepublic void run() {while (true) {try {JSONObject data = broker.poll();if (data != null) {System.out.println(Thread.currentThread().getName() + ",獲取到數據:" + data.toJSONString());}} catch (Exception e) {}}}}, "消費者");consumer.start();} }

總結

以上是生活随笔為你收集整理的如何基于多线程队列简单实现mq的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。