博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Java多线程之~~~线程安全容器的非堵塞容器
阅读量:5918 次
发布时间:2019-06-19

本文共 2081 字,大约阅读时间需要 6 分钟。

在并发编程中,会常常遇到使用容器。可是假设一个容器不是线程安全的。那么他在多线程的插入或者删除的过程

中就会出现各种问题。就是不同步的问题。所以JDK提供了线程安全的容器,他能保证容器在多线程的情况下安全的插

入和删除。当然,线程安全的容器分为两种,第一种为非堵塞似的,非堵塞的意思是当请求一个容器为空或者这个请求

不能运行的时候。就会报出异常,另外一种堵塞的意思是,不能运行的命令不会报出异常。他会等待直到他能运行。以下

我们实现一个样例,这个样例就是多个线程去大量的插入容器数据。而还有一个线程去大量的pop出数据。

代码例如以下

package com.bird.concursey.charpet9;import java.util.concurrent.ConcurrentLinkedDeque;public class AddTask implements Runnable {		private ConcurrentLinkedDeque
list; public AddTask(ConcurrentLinkedDeque
list) { super(); this.list = list; } @Override public void run() { String name = Thread.currentThread().getName(); for(int i = 0; i < 1000; i++) { list.add(name + i); } }}

package com.bird.concursey.charpet9;import java.util.concurrent.ConcurrentLinkedDeque;public class PollTask implements Runnable {		private ConcurrentLinkedDeque
list; public PollTask(ConcurrentLinkedDeque
list) { super(); this.list = list; } @Override public void run() { for(int i = 0; i < 5000; i++) { list.pollFirst(); list.pollLast(); } } public static void main(String[] args) { ConcurrentLinkedDeque
list = new ConcurrentLinkedDeque
(); Thread threads[] = new Thread[100]; for(int i = 0; i < 100; i++) { AddTask task = new AddTask(list); threads[i] = new Thread(task); threads[i].start(); } System.out.printf("Main: %d AddTask threads have been launched\n",threads.length); for(int i = 0; i < threads.length; i++) { try { threads[i].join(); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.printf("Main: Size of the List: %d\n",list.size()); for (int i=0; i< threads.length; i++){ PollTask task = new PollTask(list); threads[i] = new Thread(task); threads[i].start(); } System.out.printf("Main: %d PollTask threads have been launched\n",threads.length); for(int i = 0; i < threads.length; i++) { try { threads[i].join(); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.printf("Main: Size of the List: %d\n",list.size()); }}

转载地址:http://xsfvx.baihongyu.com/

你可能感兴趣的文章
闭包 !if(){}.call()
查看>>
关闭CentOS6启动进度条,显示详细自检信息
查看>>
垂直居中的几种实现方法
查看>>
CentOS-6.5安装配置Tomcat-7
查看>>
dubbo-admin部署在windows下tomcat报错的问题
查看>>
对于升级ubuntu libstdc++到GLIBCXX_3.4.17出错问题
查看>>
CSS定位
查看>>
通过GlusterFS黏合多节点SSD剩余空间
查看>>
Confluence 6 使用 JConsole 监控本地 Confluence
查看>>
商店销售某一商品,商店每天公布统一的折扣(discount)
查看>>
ASP.NET Web API中参数的传递方式
查看>>
U盘量产--多系统安装
查看>>
分布列表实现的简单路由过滤
查看>>
为Cacti增加Monitor、Thold插件
查看>>
我的友情链接
查看>>
Redis 知识 整理
查看>>
python MySQLdb安装和使用
查看>>
Windows 2008 r2 开启Recycle Bin
查看>>
Eclipse SVN 冲突的 介绍 及 四种解决方式
查看>>
Java基础方面二
查看>>