如何基于多线程队列简单实现mq

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相关推荐

基于多线程队列简单实现mq
public class MayiktThreadMQ { /** * Broker */ private static LinkedBlockingDeque broker = new Linked ...
基于C#实现的轻量级多线程队列
工作中我们经常会遇到一些一些功能需要实现造作日志,数据修改日志,对于这种业务需求如果我们以同步的方式实现,难免会影响到系统的性能.如下我列出集中解决方案. 使用Thread异步处理. 使用线程池或Ta ...
Linux系统编程40：多线程之基于环形队列的生产者与消费者模型
文章目录 (1)什么是信号量 (2)与信号量相关的操作 (3)基于环形队列的生产者与消费者模型-信号量(单消费者单生产者) (1)什么是信号量前面的叙述中,我们通过锁保证了每次只有一个线程进入临界区 ...
Linux系统编程39：多线程之基于阻塞队列生产者与消费者模型
文章目录 (1)生产者与消费者模型概述 (2)生产者与消费者模型优点 (3)基于阻塞队列(blockingqueue)的生产者消费者模型(单消费者单生产者) (4)基于阻塞队列(blockingque ...
微服务-多线程-队列-设计模式-MySQL-分布式事务
微服务-多线程-队列-设计模式-MySQL-分布式事务持续更新周更什么是微服务,微服务的好处微服务的几个常用组件 Eurake Hytrix 服务熔断和降级 Ribbon Feign Gatew ...
基于消息队列的分布式事务解决方案
前两天发了工资,第一反应是想着要给远方的女朋友一点惊喜!于是打开了平安银行的APP给女朋友转点钱!填写上对方招商银行卡的卡号.开户名,一键转账!搞定!在我点击的那瞬间,就收到了app的账户变动的提醒, ...
基于TCP的简单服务器
基于Tcp的简单服务器 UDP协议无连接类似于发微信 TCP协议有链接类似于打电话所以基于TCP的服务器先要到内核中获取一个TCP连接,UDP不需要获取连接 TCP的连接管理是由操作系统的内核来管理 ...
模拟QQ软件的基于多线程的流媒体加密传输软件技术
模拟QQ软件的基于多线程的流媒体加密传输软件技术模拟QQ软件,基于多线程编程捕捉摄像头及麦克风实时数据,基于socket通信设计发送端.接收端两个部分的,对音频和视频进行采集.加密或加水印.传输.解 ...
基于多线程技术和自定义消息编程实现Windows 9x异步串行通信
基于多线程技术和自定义消息编程实现Windows 9x异步串行通信张志明李蓉艳王磊摘要分析了基于Windows 95/98平台上的异步串行通信程序开发方法,并结合开发实践,用C++B ...

如何基于多线程队列简单实现mq

如何基于多线程队列简单实现mq相关推荐

最新文章

热门文章