欢迎来到天天文库
浏览记录
ID:1036496
大小:86.00 KB
页数:7页
时间:2017-11-06
《java多线程编程中两种常用并发容器讲解》由会员上传分享,免费在线阅读,更多相关内容在教育资源-天天文库。
1、Java多线程编程中的两种常用并发容器讲解这篇文章主要介绍了Java多线程编程中的两种常用并发容器讲解,分别是ConcurrentHashMap与ConcurrentHashMap,需要的朋友可以参考下ConcurrentHashMap并发容器 ConcurrentHashMap可以做到读取数据不加锁,并且其内部的结构可以让其在进行写操作的时候能够将锁的粒度保持地尽量地小,不用对整个ConcurrentHashMap加锁。ConcurrentHashMap的内部结构 ConcurrentHashMap为了提高本身的并发能力,在内部采用了一个叫做Segment的结构,一个Segment其实就是
2、一个类HashTable的结构,Segment内部维护了一个链表数组,我们用下面这一幅图来看下ConcurrentHashMap的内部结构:从上面的结构我们可以了解到,ConcurrentHashMap定位一个元素的过程需要进行两次Hash操作,第一次Hash定位到Segment,第二次Hash定位到元素所在的链表的头部,因此,这一种结构的带来的副作用是Hash的过程要比普通的HashMap要长,但是带来的好处是写操作的时候可以只对元素所在的Segment进行加锁即可,不会影响到其他的Segment,这样,在最理想的情况下,ConcurrentHashMap可以最高同时支持Segment数量大
3、小的写操作(刚好这些写操作都非常平均地分布在所有的Segment上),所以,通过这一种结构,ConcurrentHashMap的并发能力可以大大的提高。Segment 我们再来具体了解一下Segment的数据结构:staticfinalclassSegmentextendsReentrantLockimplementsSerializable{transientvolatileintcount;transientintmodCount;transientintthreshold;transientvolatileHashEntry[]table;finalfloatloa
4、dFactor;} 详细解释一下Segment里面的成员变量的意义:1.count:Segment中元素的数量2.modCount:对table的大小造成影响的操作的数量(比如put或者remove操作)3.threshold:阈值,Segment里面元素的数量超过这个值依旧就会对Segment进行扩容4.table:链表数组,数组中的每一个元素代表了一个链表的头部5.loadFactor:负载因子,用于确定thresholdHashEntry Segment中的元素是以HashEntry的形式存放在链表数组中的,看一下HashEntry的结构:staticfinalclassHashEn
5、try{finalKkey;finalinthash;volatileVvalue;finalHashEntrynext;} 可以看到HashEntry的一个特点,除了value以外,其他的几个变量都是final的,这样做是为了防止链表结构被破坏,出现ConcurrentModification的情况。ConcurrentHashMap的初始化 下面我们来结合源代码来具体分析一下ConcurrentHashMap的实现,先看下初始化方法:publicConcurrentHashMap(intinitialCapacity,floatloadFactor,intconcu
6、rrencyLevel){if(!(loadFactor>0)
7、
8、initialCapacity<0
9、
10、concurrencyLevel<=0)thrownewIllegalArgumentException();if(concurrencyLevel>MAX_SEGMENTS)concurrencyLevel=MAX_SEGMENTS;//Findpower-of-twosizesbestmatchingargumentsintsshift=0;intssize=1;while(ssize11、32-sshift;segmentMask=ssize-1;this.segments=Segment.newArray(ssize);if(initialCapacity>MAXIMUM_CAPACITY)initialCapacity=MAXIMUM_CAPACITY;intc=initialCapacity/ssize;if(c*ssize
11、32-sshift;segmentMask=ssize-1;this.segments=Segment.newArray(ssize);if(initialCapacity>MAXIMUM_CAPACITY)initialCapacity=MAXIMUM_CAPACITY;intc=initialCapacity/ssize;if(c*ssize
此文档下载收益归作者所有