【并发】8、借助redis 实现多线程生产消费阻塞队列
时间:2019-06-12
本文章向大家介绍【并发】8、借助redis 实现多线程生产消费阻塞队列,主要包括【并发】8、借助redis 实现多线程生产消费阻塞队列使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
顾名思义这个就是再消费的时候,不是之前的那哥用yield进行线程切换的操作,而是用线程等待阻塞的方式去执行,说实话我感觉效率不一定有之前那个好,
因为我对这种阻塞队列使用的时候,之前有发现阻塞队列,塞着塞着线程就会进入假死状态,这个很奇怪,但是有的时候又是好的,这个也不清楚到底是为什么
但是毕竟也是一种实现,我就写出来了看看吧
生产者
package queue.redisQueue; import queue.fqueue.vo.TempVo; import redis.clients.jedis.Jedis; import java.io.ByteArrayOutputStream; import java.io.ObjectOutputStream; import java.util.UUID; /** * @ProjectName: cutter-point * @Package: queue.redisQueue * @ClassName: RedisQueueProducter2 * @Author: xiaof * @Description: ${description} * @Date: 2019/6/12 16:29 * @Version: 1.0 */ public class RedisQueueProducter2 implements Runnable { private Jedis jedis; private String queueKey; public RedisQueueProducter2(Jedis jedis, String queueKey) { this.jedis = jedis; this.queueKey = queueKey; } @Override public void run() { while(true) { try { Thread.sleep((long) (Math.random() * 1000)); //不存在则创建,存在则直接插入 //向redis队列中存放数据 //生成数据 TempVo tempVo = new TempVo(); tempVo.setName(Thread.currentThread().getName() + ",time is:" + UUID.randomUUID()); //序列化为字节 ByteArrayOutputStream arrayOutputStream = new ByteArrayOutputStream(); ObjectOutputStream objectOutputStream = new ObjectOutputStream(arrayOutputStream); objectOutputStream.writeObject(tempVo); arrayOutputStream.flush(); try { int i = 0; while(i < 10) { long num = jedis.lpush(queueKey.getBytes(), arrayOutputStream.toByteArray()); if(num > 0) { System.out.println("成功!"); break; } ++i; } } catch (Exception e) { System.out.println("失败!"); // long num = jedis.lpush(queueKey.getBytes(), arrayOutputStream.toByteArray()); } } catch (Exception e) { e.printStackTrace(); } } } }
消费者
package queue.redisQueue; import queue.fqueue.vo.EventVo; import redis.clients.jedis.Jedis; import java.io.ByteArrayInputStream; import java.io.IOException; import java.io.ObjectInputStream; import java.util.List; /** * @ProjectName: cutter-point * @Package: queue.redisQueue * @ClassName: RedisQueueConsume2 * @Author: xiaof * @Description: ${description} * @Date: 2019/6/12 16:40 * @Version: 1.0 */ public class RedisQueueConsume2 implements Runnable { private Jedis jedis; private String queueKey; public RedisQueueConsume2(Jedis jedis, String queueKey) { this.jedis = jedis; this.queueKey = queueKey; } @Override public void run() { while(true) { List<byte[]> bytesList = null; try{ //这种就是阻塞队列模式 bytesList = jedis.blpop(0, queueKey.getBytes()); } catch (Exception e) { } //反序列化对象 if(bytesList == null || bytesList.size() <= 0) { Thread.yield(); continue; } //获取第二个对象,就是我们的字节数组 System.out.println(new String(bytesList.get(0))); ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytesList.get(1)); try { ObjectInputStream objectInputStream = new ObjectInputStream(byteArrayInputStream); EventVo eventVo = (EventVo) objectInputStream.readObject(); eventVo.doOperater(); } catch (IOException e) { e.printStackTrace(); } catch (ClassNotFoundException e) { e.printStackTrace(); } } } }
测试代码
消费队列
接下来我们把生产线程停掉
此时队列还有
我们把它消费完
当只剩最后一个的时候
可以进入下一步,好当队列为空的时候,我们再尝试去取数据的时候
队列会阻塞再这个地方,相当于是挂起线程
原文地址:https://www.cnblogs.com/cutter-point/p/11011084.html
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- js .map方法
- 【一起学系列】之模板方法:写SSO我只要5分钟
- ConcurrentDictionary线程不安全么,你难道没疑惑,你难道弄懂了么?
- 【一起学系列】之迭代器&组合:虽然有点用不上啦
- 移动端touch事件影响click事件以及在touchmove添加preventDefault导致页面无法滚动的解决方法
- 使用ActionFilterAttribute 记录 WebApi Action 请求和返回结果记录
- scipy.stats连续分布的基本操作
- InvocationHandler中invoke方法中的第一个参数proxy的用途
- height、offsetheight、clientheight、scrollheight、innerheight、outerheight
- mysql sql-mode 解析和设置
- JAVABEAN EJB POJO区别
- @Component和@Bean以及@Autowired、@Resource
- mybatis generator and 和or条件
- 『.Net反射』ILGenerator.Emit 动态MSIL 编程
- Spring通过XML配置文件以及通过注解形式来AOP 来实现前置,后置,环绕,异常通知