并发容器专门为并发而生的,最常用的就是ConcurrentHashMap、BlockingQueue了,这两个并发容器是我们比较常用的,前者取代同步Map提供了很好的并发性,后者提供了一种生产者与消费者模式的队列,ConcurrentHashMap官方介绍说了,它并没有提供在Map上加锁独占访问,这说明什么?这说明它在原子性上是没有保障的,但是它在内存可见性上是完全保证的,也就说如果你需要使用独立的线程初始化它,并且保证写并发很小的情况下,它是一个很好的缓存容器,当然我们在程序中通常也是这么用的。

下面看一个实例:

package com.home.thread.thread9;

import java.util.concurrent.ConcurrentHashMap;

/**

* @author gaoxu

* 实践出真知!

*/

public class ConcurrentHashMapInstance {

static ConcurrentHashMap, ?> chm = null;

/**

* 获取ConcurrentHashMap的全局对象

*

* @return

*/

public synchronized static ConcurrentHashMap, ?> getCHM() {

if (chm == null) {

chm = new ConcurrentHashMap();

}

return chm;

}

}

单实例的ConcurrentHashMap是一个缓存服务容器,当然是一个简陋的,通常我们会在程序启动时对其进行初始化,可以开一个线程做这件事,在这同时它的实例就已经可以对外提供服务了并且是并发的。而我们通常使用的HashMap经过同步处理也可以实现多线程缓存的服务,但是它是一个同步的操作。对于同样是Map的操作,并发性就要差了好多。

BlockingQueue就更有用了,我们经常会遇到这样的场景生产者和消费者模式,正好可以使用它来实现一个这样的中间件,当然也是很简陋的,最关键的是我们可以在这个所谓的中间件上任意的实现业务逻辑。

还有一个并发容器是我们会经常使用的,那就是ConurrentLinkedQueue,先进先出队列,它正好可以取代我们平时使用的LinkedList的方式,我们来看一个使用LinkedList来实现的对列实例。

package com.uskytec.ubs.foundation.queue;

import java.util.ArrayList;

import java.util.LinkedList;

/**

* @author gaoxu

* 实践出真知!

*/

public class RoleResourceQueue {

private static RoleResourceQueue instance = null;

private RoleResourceQueue() {

}

public synchronized static RoleResourceQueue getInstance() {

if (instance == null)

instance = new RoleResourceQueue();

return instance;

}

private final static LinkedList cache = new LinkedList();

public synchronized int add(RoleResourceQueueEntity xml) {

cache.addLast(xml);

return 1;

}

public synchronized int batchAdd(ArrayList xml) {

int xmlCount = xml.size();

int j = 0;

for (int i = 0; i < xmlCount; i++) {

RoleResourceQueueEntity apSubmit = xml.get(i);

cache.addLast(apSubmit);

j++;

}

return j;

}

public synchronized RoleResourceQueueEntity get() {

if (cache != null && cache.size() > 0)

return cache.removeFirst();

return null;

}

public synchronized int getCount() {

if (cache != null)

return cache.size();

return 0;

}

}当然还有许多没有介绍的并发容器,大多可能都是我们不常用的,如果需要可以查看jdk说明。



java 多线程并容器实现_跟着实例学习java多线程9-并发容器相关推荐

  1. java对象转xml 高性能_通过实例学习JAVA对象转成XML输出

    一.总体说明 XML和JSON 是最为常用的数据交换格式 本例子演示如何将java对象,转成XML输出. 二.流程 1.在上文的例子中,创建一个包"com.waylau.rest.bean& ...

  2. java 面试题合集_撩课-Java面试题合辑1-50题

    1.简述JDK.JRE.JVM? 一.JDK JDK(Java Development Kit) 是整个JAVA的核心, 包括了Java运行环境(Java Runtime Envirnment), 一 ...

  3. java中io是什么_深入理解Java中的IO

    深入理解Java中的IO 转载自:http://blog.csdn.net/qq_25184739/article/details/51205186 本文的目录视图如下: Java IO概要 a.Ja ...

  4. java工程师有什么要求_什么是java,java工程师应该具备哪些能力?

    这两年,虽然各种各样的新兴语言不断涌现,收获了一大批迷粉,但是java的地位,却始终难以撼动.作为一门成熟的,经久不衰的语言,java吸引了越来越多的人,想加入进来.但是,很多人在选择java前,或多 ...

  5. java虚拟机的生命周期_深入理解Java虚拟机——JVM的生命周期

    package test; public class JVMTestLife { public static void main(String[] args) { new Thread(new Run ...

  6. java如何让线程等待_如何使Java线程等待另一个线程的输出?

    我真的建议你经历一个教程,如 Sun's Java Concurrency,你开始在多线程的魔法世界. 还有一些好书出来了(google for"Concurrent Programming ...

  7. java 线程中创建线程_如何在Java 8中创建线程安全的ConcurrentHashSet?

    java 线程中创建线程 在JDK 8之前,还没有办法在Java中创建大型的线程安全的ConcurrentHashSet. java.util.concurrent包甚至没有一个名为Concurren ...

  8. java volatile有什么用_深入解析Java中volatile关键字的作用

    在java线程并发处理中,有一个关键字volatile的使用目前存在很大的混淆,以为使用这个关键字,在进行多线程并发处理的时候就可以万事大吉. Java语言是支持多线程的,为了解决线程并发的问题,在语 ...

  9. php和java的区别菜鸟教程_浅谈Java和PHP的主要区别

    当谈到PHP与Java的差异性问题时,更多的是回答初学者的一些疑问.对于刚接触IT的同学来说,他们需要做好对未来职业的选择.所以是选择PHP还是选择Java更有利于自身的技术特点和发展前景.所以在解决 ...

最新文章

  1. 【解决方案】VMWare拖动窗口后有黑色边框(分辨率自适应问题)
  2. 基于区块链的健康链系统设计与实现(6)结束语
  3. Cross-Site Scripting(XSS): 跨站脚本攻击介绍
  4. 转移指令的原理01 - 零基础入门学习汇编语言43
  5. 如何创建带有.的文件夹
  6. 相继平均法matlab代码_AHP法中平均随机一致性指标的算法及MATLAB实现
  7. 色相/饱和度趣味调节
  8. 二进制运算法则、负数的二进制补码表示与进制转换(短除法)
  9. [网络规划] 拓扑图绘图工具yED Graph Editor使用(持续更新)
  10. 超短波视距通信极限距离计算公式
  11. 500篇干货解读人工智能新时代
  12. 解释源代码文件、目标代码文件和可执行文件之间的区别
  13. java中 else if用法_java if else 用法
  14. mariadb Galera集群部署
  15. 改善到底多大 FXAA画质游戏实测
  16. “泰迪杯”挑战赛 - 基于用户协同过滤算法的电影推荐系统(附算法代码)
  17. CodeGear RAD 2007 up4最新下载及破解
  18. Shiro的 rememberMe 功能使用指导(为什么rememberMe设置了没作用?)
  19. 个体工商户注册需要税务报到吗?
  20. 使用MATLAB低版本打开高版本simulink文件

热门文章

  1. 【CF 736C】Ostap and Tree,树形DP
  2. 【BZOJ1037】【codevs1410】生日聚会,DP
  3. 【BZOJ2438】杀人游戏,tarjan缩点+简单的概率计算
  4. 【NOI2015】【codevs4600】【BZOJ4195】自动程序分析,我太弱了
  5. 2017.10.19 大陆争霸 思考记录
  6. 2017.4.19 细胞分裂 思考记录
  7. 每日小记2017.3.7
  8. 【Openstack】实录手动部署Openstack Rocky 双节点(4)- Nova
  9. 接口使用jwt返回token_Java中使用JWT生成Token进行接口鉴权实现方法
  10. java环境变量_Java的下载及环境变量的配置