- 浏览: 3498321 次
- 性别:
- 来自: 杭州
文章分类
- 全部博客 (1491)
- Hibernate (28)
- spring (37)
- struts2 (19)
- jsp (12)
- servlet (2)
- mysql (24)
- tomcat (3)
- weblogic (1)
- ajax (36)
- jquery (47)
- html (43)
- JS (32)
- ibatis (0)
- DWR (3)
- EXTJS (43)
- Linux (15)
- Maven (3)
- python (8)
- 其他 (8)
- JAVASE (6)
- java javase string (0)
- JAVA 语法 (3)
- juddiv3 (15)
- Mule (1)
- jquery easyui (2)
- mule esb (1)
- java (644)
- log4j (4)
- weka (12)
- android (257)
- web services (4)
- PHP (1)
- 算法 (18)
- 数据结构 算法 (7)
- 数据挖掘 (4)
- 期刊 (6)
- 面试 (5)
- C++ (1)
- 论文 (10)
- 工作 (1)
- 数据结构 (6)
- JAVA配置 (1)
- JAVA垃圾回收 (2)
- SVM (13)
- web st (1)
- jvm (7)
- weka libsvm (1)
- weka屈伟 (1)
- job (2)
- 排序 算法 面试 (3)
- spss (2)
- 搜索引擎 (6)
- java 爬虫 (6)
- 分布式 (1)
- data ming (1)
- eclipse (6)
- 正则表达式 (1)
- 分词器 (2)
- 张孝祥 (1)
- solr (3)
- nutch (1)
- 爬虫 (4)
- lucene (3)
- 狗日的腾讯 (1)
- 我的收藏网址 (13)
- 网络 (1)
- java 数据结构 (22)
- ACM (7)
- jboss (0)
- 大纸 (10)
- maven2 (0)
- elipse (0)
- SVN使用 (2)
- office (1)
- .net (14)
- extjs4 (2)
- zhaopin (0)
- C (2)
- spring mvc (5)
- JPA (9)
- iphone (3)
- css (3)
- 前端框架 (2)
- jui (1)
- dwz (1)
- joomla (1)
- im (1)
- web (2)
- 1 (0)
- 移动UI (1)
- java (1)
- jsoup (1)
- 管理模板 (2)
- javajava (1)
- kali (7)
- 单片机 (1)
- 嵌入式 (1)
- mybatis (2)
- layui (7)
- asp (12)
- asp.net (1)
- sql (1)
- c# (4)
- andorid (1)
- 地价 (1)
- yihuo (1)
- oracle (1)
最新评论
-
endual:
https://blog.csdn.net/chenxbxh2 ...
IE6 bug -
ice86rain:
你好,ES跑起来了吗?我的在tomcat启动时卡在这里Hibe ...
ES架构技术介绍 -
TopLongMan:
...
java public ,protect,friendly,private的方法权限(转) -
贝塔ZQ:
java实现操作word中的表格内容,用插件实现的话,可以试试 ...
java 读取 doc poi读取word中的表格(转) -
ysj570440569:
Maven多模块spring + springMVC + JP ...
Spring+SpringMVC+JPA
我们在平时的时候使用的是队列,指定好个数以后,如果放的数据超过了队列设定的个数的时候会报错误的。
那么多线程中,有一个阻塞队列的叫arrayBlockQueue。这个类是对queue在多线程中使用的扩展,
也就是说,当作为临界资源的时候,这个队列是安全,存放数据如果超过了队列设定好的初始的数据的时候,
放入数据的线程将会被等待着的。
下面来看例子。
场景模拟:
现在有两个线程,一个线程往队列里面添加数据,一个是将队列里面的数据取出来并且删掉数据。
当然,放数据的线程要速度快点,这样才能够模拟出来队列里面存放的数据的个数会超过队列起先设定好的初始的个数吧
存放的线程是每个 5 秒钟放一个数据,取得话是每个10秒钟 取一次,下面是代码 三个类:
main类
package endual; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /** * 阻塞对列,往对立里面添加元素 * 一个由数组支持的有界阻塞队列。此队列按 FIFO(先进先出) * 原则对元素进行排序。队列的头部 是在队列中存在时间最长的元素。 * 队列的尾部 是在队列中存在时间最短的元素。新元素插入到队列的尾部, * 队列检索操作则是从队列头部开始获得元素。 * *题目: *两个操作队列,一个队列是取数据,一个队列是放数据,如果一个线程取放数据过快,那么对立会阻塞, *线程也会进行等待着的 * * */ public class ArrayBlockQueueApp { public static void main(String[] args) { ArrayBlockQueueApp app = new ArrayBlockQueueApp() ; app.mian() ; } private void mian() { ExecutorService es = Executors.newCachedThreadPool() ; ArrayBlockingQueue<String> abq = new ArrayBlockingQueue<String>(10) ; ThreadGet t1 = new ThreadGet(abq); Thread t2 = new Thread(new ThreadPut(abq)) ; es.execute(t1) ; es.execute(t2) ; } }
get线程类
package endual; import java.util.concurrent.ArrayBlockingQueue; public class ThreadGet extends Thread{ ArrayBlockingQueue<String> abq = null ; public ThreadGet(ArrayBlockingQueue<String> abq) { this.abq = abq ; } public void run(){ while (true) { try { Thread.sleep(10000) ; System.out.println("我要从队列中取数据了"); String msg = abq.remove() ; System.out.println("队列里面取得的数据是:" + msg + " 队列中还的数据个数还有的 :" + abq.size()); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); }//每个十秒钟会进行拿数据出来的 } } }
取数据的线程类:
package endual; import java.util.concurrent.ArrayBlockingQueue; public class ThreadPut implements Runnable{ private ArrayBlockingQueue<String> abq = null ; public ThreadPut (ArrayBlockingQueue<String> abq) { this.abq = abq ; } public void run() { while (true) { try { System.out.println("我要向队列里面存放数据了"); Thread.sleep(5000) ; abq.put("1") ; System.out.println("当前的队列里面存放的数据的个数是:" + abq.size()); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } //向队列里面存放数据 } } }
下面是测试的结果:
我要向队列里面存放数据了 当前的队列里面存放的数据的个数是:1 我要向队列里面存放数据了 我要从队列中取数据了 队列里面取得的数据是:1 队列中还的数据个数还有的 :0 当前的队列里面存放的数据的个数是:1 我要向队列里面存放数据了 当前的队列里面存放的数据的个数是:2 我要向队列里面存放数据了 当前的队列里面存放的数据的个数是:3 我要向队列里面存放数据了 我要从队列中取数据了 队列里面取得的数据是:1 队列中还的数据个数还有的 :2 当前的队列里面存放的数据的个数是:3 我要向队列里面存放数据了 我要从队列中取数据了 队列里面取得的数据是:1 队列中还的数据个数还有的 :2 当前的队列里面存放的数据的个数是:3 我要向队列里面存放数据了 当前的队列里面存放的数据的个数是:4 我要向队列里面存放数据了 当前的队列里面存放的数据的个数是:5 我要向队列里面存放数据了 我要从队列中取数据了 队列里面取得的数据是:1 队列中还的数据个数还有的 :4 当前的队列里面存放的数据的个数是:5 我要向队列里面存放数据了 当前的队列里面存放的数据的个数是:6 我要向队列里面存放数据了 我要从队列中取数据了 队列里面取得的数据是:1 队列中还的数据个数还有的 :5 当前的队列里面存放的数据的个数是:6 我要向队列里面存放数据了 当前的队列里面存放的数据的个数是:7 我要向队列里面存放数据了 我要从队列中取数据了 队列里面取得的数据是:1 队列中还的数据个数还有的 :6 当前的队列里面存放的数据的个数是:7 我要向队列里面存放数据了 当前的队列里面存放的数据的个数是:8 我要向队列里面存放数据了 我要从队列中取数据了 队列里面取得的数据是:1 队列中还的数据个数还有的 :7 当前的队列里面存放的数据的个数是:8 我要向队列里面存放数据了 当前的队列里面存放的数据的个数是:9 我要向队列里面存放数据了 我要从队列中取数据了 队列里面取得的数据是:1 队列中还的数据个数还有的 :8 当前的队列里面存放的数据的个数是:9 我要向队列里面存放数据了 当前的队列里面存放的数据的个数是:10 我要向队列里面存放数据了 我要从队列中取数据了 队列里面取得的数据是:1 队列中还的数据个数还有的 :9 当前的队列里面存放的数据的个数是:10 我要向队列里面存放数据了 我要从队列中取数据了 当前的队列里面存放的数据的个数是:10 我要向队列里面存放数据了 队列里面取得的数据是:1 队列中还的数据个数还有的 :10 我要从队列中取数据了 当前的队列里面存放的数据的个数是:10 我要向队列里面存放数据了 队列里面取得的数据是:1 队列中还的数据个数还有的 :10 我要从队列中取数据了 当前的队列里面存放的数据的个数是:10 我要向队列里面存放数据了 队列里面取得的数据是:1 队列中还的数据个数还有的 :10 我要从队列中取数据了 当前的队列里面存放的数据的个数是:10 我要向队列里面存放数据了 队列里面取得的数据是:1 队列中还的数据个数还有的 :10
部分的结果。。。。。。
我们从结果中可以看出来,当队列里面的数据达到10个的时候,存放数据的线程在存放的时候将等待队列少的位子,不会像队列里面的数据少于10个的时候,存放数据是无需等待的,5秒钟到了就马上放进去。而到了10个数据的时候,存放的那个现在到了5秒钟的时候,还必须在等待位子,因为队列中还是10个位子,只有当取数据的线程取出数据以后,空出来的
位子后马上就添加进去了的
评论
4 楼
FYIHDG
2013-12-25
3 楼
endual
2012-07-06
502220545 写道
502220545 写道
您好 看了您写的例子 有一点小小的建议
1 当放数据的睡眠时间 大于 取数据的睡眠时间时 就会跑出异常
可以将 arrayBlockingQueue的 add和remove方法 换成 put 和 take 这样就不会报异常了 是以阻塞的形式运行的
1 当放数据的睡眠时间 大于 取数据的睡眠时间时 就会跑出异常
可以将 arrayBlockingQueue的 add和remove方法 换成 put 和 take 这样就不会报异常了 是以阻塞的形式运行的
sorry 看错了 然后自己写错了 抱歉
没关系,我的文章很少有朋友给我提建议的,我大多是转的。呵呵。
这篇到是自己写的
2 楼
502220545
2012-07-06
502220545 写道
您好 看了您写的例子 有一点小小的建议
1 当放数据的睡眠时间 大于 取数据的睡眠时间时 就会跑出异常
可以将 arrayBlockingQueue的 add和remove方法 换成 put 和 take 这样就不会报异常了 是以阻塞的形式运行的
1 当放数据的睡眠时间 大于 取数据的睡眠时间时 就会跑出异常
可以将 arrayBlockingQueue的 add和remove方法 换成 put 和 take 这样就不会报异常了 是以阻塞的形式运行的
sorry 看错了 然后自己写错了 抱歉
1 楼
502220545
2012-07-06
您好 看了您写的例子 有一点小小的建议
1 当放数据的睡眠时间 大于 取数据的睡眠时间时 就会跑出异常
可以将 arrayBlockingQueue的 add和remove方法 换成 put 和 take 这样就不会报异常了 是以阻塞的形式运行的
1 当放数据的睡眠时间 大于 取数据的睡眠时间时 就会跑出异常
可以将 arrayBlockingQueue的 add和remove方法 换成 put 和 take 这样就不会报异常了 是以阻塞的形式运行的
发表评论
-
snmp
2020-04-13 11:07 383https://www.iteye.com/blog/zhan ... -
snmp
2020-04-10 21:33 513https://blog.csdn.net/qq_333141 ... -
服务器监控软件
2019-12-31 11:07 459[ERROR] org.hyperic.sigar.Sigar ... -
多数据源
2019-12-23 22:09 399https://gitee.com/baomidou/dyna ... -
mybatis多数据源
2019-12-23 18:09 400https://blog.csdn.net/qq_288042 ... -
springboot ueditor
2019-12-17 18:26 338https://blog.csdn.net/u01216982 ... -
java支持多数据源
2019-12-13 15:59 405spxcms是否支持多数据源 ... -
java日志
2019-12-10 12:01 253https://blog.csdn.net/peng_wei_ ... -
spring 多数据源
2019-12-06 09:55 382https://www.jb51.net/article/10 ... -
idea
2019-12-04 17:13 355https://blog.csdn.net/dengachao ... -
手机大屏
2019-11-30 16:02 292http://demo.demohuo.top/modals/ ... -
quarz配置
2019-11-08 11:48 410https://blog.csdn.net/BryantLmm ... -
mysql同步
2019-11-06 12:20 287https://blog.csdn.net/baidu_418 ... -
nginx配置多个服务
2019-11-04 20:35 701https://blog.csdn.net/everljs/a ... -
h5 加壳
2019-11-04 16:05 573https://jingyan.baidu.com/artic ... -
jeui 前端框架
2019-10-22 14:30 1108http://www.jemui.com/demo/ http ... -
jeui 维护
2019-10-22 14:29 2http://www.jemui.com/demo/ htt ... -
jeui 维护
2019-10-22 14:29 2http://www.jemui.com/demo/ -
jeui 维护
2019-10-22 14:29 2http://www.jemui.com/demo/ -
jeui 维护
2019-10-22 14:29 2http://www.jemui.com/demo/
相关推荐
java多线程模拟队列实现排队叫号,多线程模拟排队叫号取号 java多线程模拟队列实现排队叫号,多线程模拟排队叫号取号
java多线程加队列上传文件_后台处理
Java多线程读大文件 java多线程写文件:多线程往队列中写入数据
java 多线程 队列工厂
实现java模拟阻塞队列的例子,该代码包括,阻塞队列实现生产者,消费者。和模拟阻塞队列实现生产者及消费者模式,帮助你更好的理解java多线程
支持多线程的阻塞队列,使用模板技术,可存储任意类型数据
一个线程从A表读数据放入队列 N个线程从队列中取出数据,找到其在子表中的数据 对子表中的数据开3种线程:读,发email,标记状态 N个线程对完成的A表数据做最后处理 支持大数据量跑批,就是个例子,本来是公司发送...
Java多线程设计模式上传文件Java多线程设计模式上传文件Java多线程设计模式上传文件Java多线程设计模式上传文件Java多线程设计模式上传文件Java多线程设计模式上传文件Java多线程设计模式上传文件Java多线程设计模式...
idea+java多线程模拟队列实现排队叫号.zip
易语言简单的多线程消息队列。@Patek。
《秒杀多线程第十六篇 多线程十大经典案例之一 双线程读写队列数据》 ...为了让大家更加熟练运用多线程,将会有十篇文章来讲解十个多线程使用案例,相信看完这十篇后会让你能更加游刃有余的使用多线程。
java多线程经典案例,线程同步、线程通信、线程阻塞等经典案例
java多线程PPT 多线程基本概念 创建线程的方式 线程的挂起与唤醒 多线程问题
java多线程并发查询数据库,使用线程池控制分页,并发查询。
详细的讲解了java多线程的原理,并配有代码进行实战,适合java初学者和想对多线程有进一步了解的人。
一个java 多线程操作数据库应用程序!!!
Java 线程系列博文总结word化,编目如下,欢迎互相学习交流: ...Java线程:新特征-阻塞队列 Java线程:新特征-阻塞栈 Java线程:新特征-条件变量 Java线程:新特征-原子量 Java线程:新特征-障碍器
java多线程的使用方法如何使用,怎么使用,使用过程中有什么要注意的