开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

并发Hashmap initTable()为什么会阻塞try/finally？

并发HashMap是Java中的一个线程安全的哈希表实现，用于在多线程环境下进行高效的键值对存储和访问。其中的initTable()方法用于初始化哈希表的数据结构。

在并发HashMap的实现中，哈希表被分割成多个段（Segment），每个段维护着一部分键值对。initTable()方法的作用是创建并初始化这些段。

在initTable()方法中，会使用try/finally语句块来确保线程安全。具体原因如下：

并发环境下的安全性：由于并发HashMap是线程安全的，多个线程可以同时访问和修改哈希表。为了保证在初始化过程中不会发生竞态条件（race condition），需要对关键代码段进行同步控制。
异常处理：try/finally语句块可以确保即使在初始化过程中发生异常，也能正确释放资源。在initTable()方法中，如果在初始化过程中发生异常，finally块中的代码会被执行，确保释放相关资源，避免资源泄漏。

总结起来，initTable()方法会阻塞try/finally语句块是为了保证并发环境下的线程安全性，并且能够正确处理异常情况。

关于并发HashMap的更多信息，你可以参考腾讯云的产品文档：

页面内容是否对你有帮助？

有帮助

没帮助

相关·内容

ConcurrentHashMap锁机制进化的考量

我们知道，HashMap是无法保证线程安全性的，如果在并发环境下插入一个HashMap，哈希桶数组扩容时，有可能会造成链表出现环（美团技术的文章有详解）。...null : scanAndLockForPut(key, hash, value); V oldValue; try { HashEntry[...count = c; oldValue = null; break; } } } finally...如果重试达到上限还未成功，就直接调用lock()方法阻塞，等待锁被其他线程释放。注意在重试的最后会检测对应的HashEntry是否发生了变化，如果变化了，会重新开始自旋。...本线程插入完毕之后，调用ReentrantLock.unlock()方法释放锁，同时唤醒AQS队列中阻塞着的下一个线程（如果有的话）进行插入操作，执行完毕。

1.6K2 0

HashMap很美好，但线程不安全怎么办？ConcurrentHashMap告诉你答案！

很多小伙伴可能第一时间想到了HashTable，因为它和HashMap拥有者相似的功能，底层也是基于哈希表实现，数组+链表构建，数组容量到达阈值后，同样会自动扩容，Hashtable 默认的初始大小为...当一个线程访问同步方法时，其他线程也访问同步方法，可能会进入阻塞或轮询状态，如使用 put 添加元素，另一个线程不能使用 put 添加元素，也不能使用 get，竞争会越来越激烈效率越低。...，会转为红黑树，这和HashMap一样。...initialization race; just spin else if (U.compareAndSwapInt(this, SIZECTL, sc, -1)) { try...而1.8的版本中，Node是一个数组，初始默认为16，后续仍然可以以2的幂次方级别进行扩容，因此，它所支持的并发量要看它数组的真实容量；效率高是因为它底层采用了和JDK1.8中HashMap相同的数组

1170 0

【JAVA】ConcurrentHashMap 如何实现高效地线程安全？

具体选择要看开发的场景需求，总体来说，并发包内提供的容器通用场景，远优于早期的简单同步实现。正文 1、为什么需要 ConcurrentHashMap？...前面已经提过 HashMap 不是线程安全的，并发情况会导致类似 CPU 占用 100% 等一些问题，那么能不能利用 Collections 提供的同步包装器来解决问题呢？...2、ConcurrentHashMap 分析我们再来看看 ConcurrentHashMap 是如何设计实现的，为什么它能大大提高并发效率。...： ConcurrentHashMap 会获取再入锁，以保证数据一致性，Segment 本身就是基于 ReentrantLock 的扩展实现，所以，在并发修改期间，相应 Segment 是被锁定的。...试想，如果不进行同步，简单的计算所有 Segment 的总值，可能会因为并发 put，导致结果不准确，但是直接锁定所有 Segment 进行计算，就会变得非常昂贵。

2663 0

呕心沥血，独到的见解：JUC集合类，独到的见解。

为什么需要concurrentHashMap，分析HashMap因为Collecitons.synchronizedMap是给操作加上锁，并发效率低 为什么HashMap线程不安全？...Queue（阻塞队列、非阻塞队列）并发队列不只是阻塞队列，还有非阻塞队列为什么使用队列用队列在线程间传递数据：生产消费模式、银行转账考虑线程安全的问题，从你转移到了队列上并发队列简介Queue 保存一组等待的数据...那就是队列先进先出的特性，要满足，不会先链表一样可以取到中间的数据 BlokingQueue在queue的基础上增加了阻塞的特性，队列满的时候，放数据的时候会阻塞，队列空的时候，取数据的时候会阻塞。...并发队列关系图阻塞队列！***重要什么是阻塞队列顾名思义。...reenrantLock无界队列，这里点一下，linkedBlockingQueue和这个优先级blockingQueue的put是不会阻塞的，因为无界限，但是take会，空了就要等可以理解为是PriorityQueue

3932 0

Java 8 ConcurrentHashMap源码中竟然隐藏着两个BUG

，关键点在于自旋锁的使用，当有多个线程都执行initTable方法的时候，CAS可以保证只有一个线程能够进入到真正的初始化分支，其他线程都是自旋等待。...这里就有一个问题，按照我们前面的分析，扩容线程能够通力协作，保证各自负责的桶数组的分段不重不漏，这里为什么还需要做二次确认么？...具体的复制过程与HashMap类似，感兴趣的读者可以翻一下高端的面试从来不会在HashMap的红黑树上纠缠太多这篇文章。...= null则后面的CAS是不会执行的，为什么要这么设置呢？作者有两点考虑：原因在于如果(as = counterCells) !...细节三：在加锁的时候先判断下cellsBusy是否为0，如果为1那直接宣告拿锁失败，为什么这么做呢？

7864 0

详解ConCurrentHashMap源码（jdk1.8）

ConCurrentHashMap是一个支持高并发集合，常用的集合之一，在jdk1.8中ConCurrentHashMap的结构和操作和HashMap都很类似：数据结构基于数组+链表/红黑树。...唯一不同的是，HashMap不支持并发操作，ConCurrentHashMap是支持并发操作的。...ConcurrentHashMap键值对为什么都不能为null,而HashMap就可以？...HashMap是非并发的，可以通过contains(key)判断，而支持并发的ConcurrentHashMap在调用contains方法和get方法的时候，map可能已经不同了。...参考 为什么ConcurrentHashMap的读操作不需要加锁 Java并发——ConcurrentHashMap(JDK 1.8）

2703 0

走近concurrentHashMap（JDK1.8）

前言前面我们学习了HashMap的数据结构，分析了其源码在本篇文章中与HashMap相同的部分就不在赘述，但是HashMap是线程不安全的容器，在多线程环境下会有线程完全问题，虽然也有线程安全容器Hashtable...在扩容，设值的过程中大量采用CAS无锁不阻塞的方式支持并发操作，但是是不是就不需要加锁了呢？答案是否定的。...初始化initTable方法 private final Node[] initTable() { Node[] tab; int sc; while...与HashMap类似，put操作采用CAS+synchronized实现并发插入或更新操作。其主要的过程也是如下几步： 1.计算hash值，然后根据hash值计算出key的存储位置i。...说明： 5.获取index位置上的元素是通过 U.getObjectVolatile 来获取的，而不是直接通过table[index] 这是为什么呢？

2724 0

精妙绝伦的并发艺术品 — ConcurrentHashMap是如何保证线程安全的

ConcurrentHashMap并发效率是如何提高的？和加锁相比较，为什么它比HashTable效率高？...）、CAS（乐观锁，减小上下文切换开销，无阻塞）等等技术，下面来具体看看吧 | 初始化数据结构时的线程安全 HashMap的底层数据结构这里简单带过一下，不做过多赘述：大致是以一个Node对象数组来存放数据...(); ... } 此时是会有并发问题的，如果多个线程同时调用initTable初始化Node数组怎么办？...|扩容操作的线程安全在扩容时，ConcurrentHashMap支持多线程并发扩容，在扩容过程中同时支持get查数据，若有线程put数据，还会帮助一起扩容，这种无阻塞算法，将并行最大化的设计，堪称一绝...大部分的单机数据查询优化方案都会降低并发性能，就像缓存的存储，在多线程环境下将有并发问题，所以会产生并行或者一系列并发冲突锁竞争的问题，降低了并发性能。

9454 0

学习Java基础知识，打通面试关九~ConcurrentHashMap

在上一篇文章中我们说到了Map集合中的一部分内容，还有并发包中的Map并没有说到，现在我们来说下并发包中的Map~ConcurrentHashMap。...ConcurrentHashMap 中并发度默认是16 但是我们可以在构造函数的时候进行设置。设置时该值需要设置成2的幂数值。不符合规则的数值设置会自动的调整成符规则的设置的数值。...ConcurrentHashMap 也存在扩容的问题，这个跟HashMap类似，但是不是针对的整个ConcurrentHashMap,而是单独对Segment进行扩容。也会遇到同样的操作错误。...初始化方法时使用的initTable，在调用的时候进行参数的设置。主要是设置sizeCtl该属性，如果发现有竞争性的初识化，那么就自旋等待恢复。...(U.compareAndSwapInt(this, SIZECTL, sc, -1)) {//利用CAS方法把sizectl的值置为-1 表示本线程正在进行初始化 try

4342 0

如何保证容器是线程安全的？ ConcurrentHashMap 如何高效的线程安全？

理解基本的线程安全工具理解传统集合矿建并发变成中 Map 存在的问题，清楚简单同步方式的不足梳理并发包内，尤其是 ConcurrentHashMap 采取了哪些方法来提高并发表现。...为什么需要 ConcurrentHashMap Hashtable 是怎样实现线程安全的。...ConcurrentHashMap 为什么能够大大提高并发效率？ConcurrentHashMap 的设计一直在演化，比如在 Java 8 中就发生发生了很大变化。...试想，如果不进行同步，简单的计算所有 Segment的总值，可能会因为并发put，导致结果不准确，但是直接锁定所有 Segment进行计算，就会变得非常昂贵。...JDK 8 ConcurentHashMap 是怎么进行 inittable 的？

1.1K3 0

突击并发编程JUC系列-并发容器ConcurrentHashMap

ConcurrentHashMap是线程安全且高效的HashMap。 为什么要使用ConcurrentHashMap 在并发编程中使用HashMap可能导致程序死循环。...线程不安全的HashMap 在多线程环境下，使用HashMap进行put操作会引起死循环，导致CPU利用率接近100%，所以在并发情况下不能使用HashMap。例如，执行以下代码会引起死循环。...在并发执行put操作时会引起死循环，是因为多线程会导致HashMap的 Entry 链表形成环形数据结构，一旦形成环形数据结构，Entry 的 next 节点永远不为空，就会产生死循环获取 Entry。...因为当一个线程访问HashTable的同步方法，其他线程也访问HashTable的同步方法时，会进入阻塞或轮询状态。...sc = n - (n >>> 2); } } finally { // 初始化成功设置 sizeCtl sizeCtl =

3857 1

ConcurrentHashMap是如何实现线程安全的

ConcurrentHashMap并发效率是如何提高的？和加锁相比较，为什么它比HashTable效率高？...）、CAS（乐观锁，减小上下文切换开销，无阻塞）等等技术，下面来具体看看吧初始化数据结构时的线程安全 HashMap的底层数据结构这里简单带过一下，不做过多赘述：大致是以一个Node对象数组来存放数据...(); ... } 此时是会有并发问题的，如果多个线程同时调用initTable初始化Node数组怎么办？...大部分的单机数据查询优化方案都会降低并发性能，就像缓存的存储，在多线程环境下将有并发问题，所以会产生并行或者一系列并发冲突锁竞争的问题，降低了并发性能。...试想一下，如果是你，你会如何设计这种热点数据？是加锁，还是进行CAS操作？进入ConcurrentHashMap中，看看大师是如何巧妙的运用了并发技巧，提高热点数据的并发性能。

5331 0

Java同步容器和并发容器

Vector 是线程安全的，为什么还会报这个错？...ConcurrentHashMap - 线程安全的 HashMap。采用分段锁实现高效并发。 ConcurrentSkipListMap - 线程安全的有序 Map。使用跳表实现高效并发。...ArrayBlockingQueue - 数组实现的阻塞队列。 LinkedBlockingQueue - 链表实现的阻塞队列。...LinkedBlockingDeque - 双向链表实现的双端阻塞队列。 ConcurrentHashMap 要点作用：ConcurrentHashMap 是线程安全的 HashMap。...在并发迭代访问时会抛出 ConcurrentModificationException 异常 // Map map = new HashMap<

6805 0

ConcurrentHashMap源码阅读

前言 HashMap是非线程安全的，在多线程访问时没有同步机制，并发场景下put操作可能导致同一数组下的链表形成闭环，get时候出现死循环，导致CPU利用率接近100%。...因为线程1调用HashTable的put同步方法时，线程2的put或get等方法则进入阻塞状态，所以竞争越激烈，效率越低。...，put操作就是要在HashMap中寻找对应的key是否存在，如果存在则更新value，如不存在则新建一个HashEntry。...put需要加锁，使用了ReetrantLock的tryLock的非阻塞加锁方法。...public int size() { // Try a few times to get accurate count.

1.1K7 0

【java基础】ConcurrentHashMap1.7和1.8的不同实现

ConcurrentHashMap 在多线程环境下，使用HashMap进行put操作时存在丢失数据的情况，为了避免这种bug的隐患，强烈建议使用ConcurrentHashMap代替HashMap，为了对...方法的次数超过上限时，则执行lock()方法挂起线程B； 3、当线程A执行完插入操作时，会通过unlock()方法释放锁，接着唤醒线程B继续执行； size实现因为ConcurrentHashMap是可以并发插入数据的...对象中的元素个数，然后进行累加，但是这种方式计算出来的结果并不一样的准确的，因为在计算后面几个Segment的元素个数时，已经计算过的Segment同时可能有数据的插入或则删除，在1.7的实现中，采用了如下方式： try...只有在执行第一次put方法时才会调用initTable()初始化Node数组，实现如下： private final Node[] initTable() { Node[]...，如果存在两个线程同时执行CAS修改baseCount值，则失败的线程会继续执行方法体中的逻辑，使用CounterCell记录元素个数的变化； 2、如果CounterCell数组counterCells

5073 1

Juc并发编程11——深入源码：常用并发容器、阻塞队列使用与原理

前言本文将介绍常用的并发容器，比较传统容器与并发容器的区别，介绍并发容器的基本原理。是面试常考、工作常用的热门知识点。深入源码：常用并发容器、阻塞队列使用与原理前言 1.传统容器安全吗？...总的来说，就是由于ArrayList的扩容与元素增加操作为非原子性操作，导致出现了并发安全的问题。再来看看HashMap。...3.1 阻塞队列的介绍除了常用的并发容器以外，juc还提供了各种阻塞队列，适用于不同的工作场景。...super E> c, int maxElements); } 阻塞队列会阻塞线程，不废话，上图。还记得消费者与生产者模式吗？利用阻塞队列可以很轻松的进行实现。下面我们来实战下。...，也就是说，上面代码的put操作相当于ArrayBlockingQueue在队列满了时进行put操作，会导致线程阻塞。

3093 0

JDK8的ConcurrentHashMap源码学习笔记

正文: 目标首要目标:保持并发的可读性,同时最小化更新产生的竞争次要目标:保持与HashMap相同或更好的空间消耗,并支持许多线程在空表上的高初始插入率。...*/ private final Node[] initTable() { Node[] tab; int sc; //volatile读 while ((tab...sizeCtl) < 0) Thread.yield(); // lost initialization race; just spin //第一次put操作的线程会执行...>[n]; table = nt; sc = n - (n >>> 2); } } finally {...HashMap要好，但是在单线程环境下，HashMap会比ConcurrentHashMap好一点参考链接深入分析ConcurrentHashMap1.8的扩容实现 seaswalker/JDK 晚安

7584 0

ReadWriteLock 读写锁实现一个缓存

概述关注公众号 JavaStorm 学习更多干货实际工作中我们会遇到一种并发场景：读多写少，这个时候为了优化性能，我们就会使用缓存。...为什么我们要再次验证呢？...此时线程 T2 和 T3 会再有一个线程能够获取写锁，假设是 T2，如果不采用再次验证的方式，此时 T2 会再次查询数据库。T2 释放写锁之后，T3 也会再次查询一次数据库。...，最终导致相关线程都被阻塞，永远也没有机会被唤醒。...，最终导致相关线程都被阻塞，永远也没有机会被唤醒。

9962 0

JDK 8 ConcurrentHashMap源码解读

7和8 的结构还是有些不一样；7里面是Segment、entry数组实现的，将entry数组分段加锁，而8里是对数组元素加锁，并发上增加了一个counterCells的数组记录并发时增加的值，然后通过cas...if (tab == null || (n = tab.length) == 0) // 初始化数组 tab = initTable...assert checkInvariants(root); return null; } 初始化数组 private final Node[] initTable...就是在并发时，同时修改baseCount，要么成功、要么等待（阻塞），它呢用countCell[] 数组来记录线程在修改baseCount失败时所加的数值，当线程A在修改baseCount，线程B来了，...synchronized (f) { // 对要转移的索引位置对象枷锁后 // 下面的转移逻辑和hashMap

2811 0

JDK1.8的ConcurrentHashMap源码解析

系列传送门： Java并发包源码学习系列：AbstractQueuedSynchronizer Java并发包源码学习系列：CLH同步队列及同步资源获取与释放 Java并发包源码学习系列：AQS共享式与独占式获取与释放资源的区别...为什么要使用ConcurrentHashMap? 在思考这个问题之前，我们可以思考：如果不用ConcurrentHashMap的话，有哪些其他的容器供我们选择呢？并且它们的缺陷是什么？...public synchronized V put(K key, V value) { // ... } HashMap JDK1.8版本的HashMap在读取hash槽的时候读取的是工作内存中引用指向的对象...Java8之后 JDK1.8之后采用CAS + Synchronized的方式来保证并发安全。采用【Node数组】加【链表】加【红黑树】的结构，与HashMap类似。...接下来将会具体分析一下几个关键的方法 initTable 采用延迟初始化，第一次put的时候，调用initTable()初始化Node数组。

1723 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

运营活动

活动名称

广告关闭