假设一个应用场景:需要模拟车辆一天的运行轨迹,并且实时监控,就需要不断的像已有的数据集合中添加新的数据,并且遍历集合。
在传统的java集合包中的集合中像 ArrayList HashMap等;在同一线程中传统集合是不允许修改的,也就是遍历时不能修改,添加,删除等操作。多个线程就更不行了。
为此java.util.concurrent包中提出了一些解决方法:
使用Collections.synchronizedList() ,new CopyOnWriteArrayList<String>() 等,将集合包装为安全的集合,这样确实是结局了同步的问题。其内部的原理,就是将资源synchronized ,本身没有解决问题,因为ArrayList本身是不支持并发的,这样只会当多个线程都在争用这个资源的时候,效率就会急剧下降。
jdk 1.7 提出了java.util.concurrent.ConcurrentLinkedDeque 非阻塞的线程安全列表
ConcurrentLinkedDeque 是线程安全的,插入,删除和其它的操作可以同时执行,但是不允许插入空值。
注意:如果在进行添加和删除操作的同时也在执行迭代操作,那么此时将不会返回正确的值。
ConcurrentLinkedDeque的主要方法:
add() and offer(): 因为ConcurrentLinkedDeque是线程安全的集合,所有add方法总是返回true,和add一样offer方法也是添加一个元素,总是返回true。
poll() : 获取队列中的第一个元素并同时删除元素,如果没有获取到,返回null(此时并没有)
peek(): 和poll() 一样,不同的是,peek()不会移除元素。
element():和poll()一样,不同的是,element()在没找到时候会抛出NoSuchElementException异常。
简单的示例:
public class ConcurrentLinkedDequeDemo {
static ConcurrentLinkedDeque<String> cld = new ConcurrentLinkedDeque<String>();
public static void main(String[] args) {
//新建一个线程池
ExecutorService exService = Executors.newFixedThreadPool(2);
ThreadOne elementAdd = new ConcurrentLinkedDequeDemo().new ThreadOne();
ThreadTwo elementGet = new ConcurrentLinkedDequeDemo().new ThreadTwo();
//在主线程上执行 add 和 get 线程
exService.execute(elementAdd);
exService.execute(elementGet);
exService.shutdown();
}
class ThreadOne implements Runnable {
@Override
public void run() {
for (int i = 0; i < 5; i++) {
cld.add("A" + i);
System.out.println("Element added is: A" +i );
}
}
}
class ThreadTwo implements Runnable {
@Override
public void run() {
for (int i = 0; i < 5; i++) {
// String s = cld.poll();
String s = cld.peek ();
// String s = cld.element ();
System.out.println("Element received is: " + s);
}
}
}
}
执行结果:
poll():
Element received is: null
Element added is: A0
Element received is: A0
Element added is: A1
Element received is: A1
Element added is: A2
Element received is: A2
Element added is: A3
Element received is: A3
Element added is: A4
peek():
Element received is: null
Element added is: A0
Element received is: A0
Element added is: A1
Element received is: A0
Element added is: A2
Element received is: A0
Element received is: A0
Element added is: A3
Element added is: A4
element():
Element added is: A0
Element added is: A1
Element added is: A2
Element added is: A3
Element added is: A4
Exception in thread "pool-1-thread-2" java.util.NoSuchElementException
at java.util.concurrent.ConcurrentLinkedDeque.screenNullResult(ConcurrentLinkedDeque.java:812)
at java.util.concurrent.ConcurrentLinkedDeque.getFirst(ConcurrentLinkedDeque.java:956)
at java.util.concurrent.ConcurrentLinkedDeque.element(ConcurrentLinkedDeque.java:1030)
at com.dx.java.jdk.ConcurrentLinkedDequeDemo$ThreadTwo.run(ConcurrentLinkedDequeDemo.java:41)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
分享到:
相关推荐
jdk1.7_linux Linux版零积分jdk1.7_linux Linux版零积分免费下载jdk1.7_linux Linux版零积分免费下载jdk1.7_linux Linux版零积分免费下载jdk1.7_linux Linux版零积分免费下载jdk1.7_linux Linux版零积分免费下载jdk...
jdk1.7版本免安装
jdk 1.7 64位jdk 1.7 64位jdk 1.7 64位jdk 1.7 64位jdk 1.7 64位jdk 1.7 6
java jdk 1.7官网免安装版本,解压就可以直接使用,不用再官网登录账号就可以直接下载,省去很多麻烦,不用各种等待,直接使用csdn平台就可以直接下载。
java jdk1.7源码包,用于centos7使用jdk1.7编译openjdk1.8的 1.7版本
linux 64位 jdk1.7,使用tar -xvf可以解压文件,配置环境变量即可
jdk1.7 windows 32: Windows 32位下的JDK1.7 请注意不要下错了 无需安装,解压即可 注意设置环境变量 本资源分为两部分,都在我空间里(csdn不允许文件超过60M)
java jdk1.7.zip 64位,喜欢就拿去吧!!!!!!!!!
jdk1.7 64位下载
jdk1.7 32位 官方正式版 jdk-7u79-windows-i586 JDK详细介绍 JDK(Java Development Kit) 是 Java 语言的软件开发工具包(SDK)。 SE(J2SE),standard edition,标准版,是我们通常用的一个版本,从JDK 5.0开始,改名...
java运行环境 jdk1.7u80 jar 64bit 64位jdk下载,上传限制文件分3部分上传,第三部分
这是Jdk1.7的压缩包,解压完成后在环境变量中配置JAVA_HOME以及path以后就可以用啦。检查是否配置好:win+r进入cmd,输入java -version,如出现版本号即为配置成功。
JDK1.7新特性介绍 1. 对Java集合(Collections)的增强支持 2. 在Switch中可用String 在JDK7 的正式版本中,你可以在switch的表达式中用String类型 3. 数值可加下划线 下划线字符(_)能够出现在数字字面量的数字...
springboot,mybatis, jdk1.7,搭建好的空项目,可以自动生成entity.mapper.mapper.xml.好用
64位linux jdk1.7,jdk-7u79-linux-x64.tar.gz版本,从sun的官网上下载的
jdk1.7
jdk1.7 64位官方正式版 jdk-7u71-macosx-x64.dmg
此版本为java1.7的解压缩版本,满足广大程序员对于JDK1.7的需求
jdk1.7-linux..