`
yourenyouyu2008
  • 浏览: 287553 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Map和ConcurrentMap

 
阅读更多

ConcurrentMap为map增加原子方法,用于同步操作。

V putIfAbsent(K key, V value);

如果map中还没有key就添加,有key就直接返回key对应的value

     * <pre>
     *   if (!map.containsKey(key))
     *       return map.put(key, value);

//put方法the previous value associated with key, or null if there was no mapping for key
     *   else
     *       return map.get(key);</pre>

使用示例:确保并发情况下同一个type不好创建多次

List<WebSocketMessageInbound> connects = connections.get(type);
        if (null == connects) {
            connects = new ArrayList<WebSocketMessageInbound>();
            connects=connections.putIfAbsent(type, connects);//connects is null
            connects=connections.get(type);////connects is not null
        }
        return connects;

 

boolean remove(Object key, Object value);

if (map.containsKey(key) &amp;&amp; map.get(key).equals(value)) {
     *       map.remove(key);
     *       return true;
     *   } else return false;

 

boolean replace(K key, V oldValue, V newValue);

 

 

V replace(K key, V value);

 

Map

put 方法 return:the previous value associated with key, or null if there was no mapping for key

返回的是上一次的值而不是本次set的值

 

List<WebSocketMessageInbound> connects = connections.get(type);
        if (null == connects) {
            connects = new ArrayList<WebSocketMessageInbound>();
            connects=connections.putIfAbsent(type, connects);//connects is null
            connects=connections.get(type);////connects is not null
        }
        return connects;

分享到:
评论

相关推荐

    concurrent-map, go的线程安全并发映射.zip

    concurrent-map, go的线程安全并发映射 并发映射 这里解释了和这里的,go的map 类型不支持并发读和写。 concurrent-map 为这个提供了一个高性能解决方案,通过分割等待锁定的最小时间。go之前,在stdlib中没有并发...

    concurrentmap

    concurrentMap := concurrentmap . New ( concurrentmap . WithBucket ( 32 )) concurrentMap . Store ( "1" , 1 ) if v , ok := concurrentMap . Load ( "1" ); ok { fmt . Printf ( " v = %v \n " , v ) ...

    Java-concurrentMap-内存模型深入分析-HotCode

    JMM规定了内存的可见性、原子性和有序性,这对于理解`concurrentMap`的工作机制至关重要。例如,`ConcurrentHashMap`使用了分段锁策略,每个段都是一个独立的`HashMap`,通过并发控制减少锁的粒度,提高并发性能。...

    ConcurrentMap.putIfAbsent(key,value)用法实例

    ConcurrentMap.putIfAbsent(key, value) 用法实例 ConcurrentMap.putIfAbsent(key, value) 是一种 atomic 操作,用于在并发环境下安全地将键值对添加到 Map 中。这个方法主要是为了解决 put-if-absent 操作中的 ...

    Java里多个Map的性能比较(TreeMap、HashMap、ConcurrentSkipListMap)

    在Java编程中,Map接口是用于存储键值对的数据结构,而Java提供了多种Map的实现,包括TreeMap、HashMap和ConcurrentSkipListMap。本文主要比较了这三种Map的性能,尤其是在插入和查找操作上的效率。 1. **TreeMap**...

    开源项目-streamrail-concurrent-map.zip

    在“concurrent-map-master”目录下,我们可以找到项目的源代码、测试文件和其他相关文档。源代码通常会包含一个或多个Go文件(`.go`),这些文件实现了并发映射的接口和内部数据结构。常见的设计模式可能是将数据...

    Map集合的继承关系图.pdf

    3. ConcurrentMap:这个接口的实现提供了针对并发访问和更新操作的原子操作,通常用在多线程环境中。 4. Map.Entry:Map内部的一个私有静态接口,用于表示键值对。 在Map接口的实现类中,有几个最为常用的实现: 1...

    spring-session-sample-map:使用ConcurrentMap作为会话存储的Spring Boot上的Spring Session

    使用ConcurrentMap作为会话存储的Spring Boot上的Spring Session 演示将Spring Session与Spring Boot和Spring Security结合使用。 您可以使用用户名“ user”和密码“ password”登录。 将会话数据存储在Concurrent...

    加锁方法对于Map

    在Java编程中,Map接口是数据结构中非常重要的一个部分,它提供了键值对的存储方式,便于我们高效地管理和操作数据。当我们需要在多线程环境下保证Map操作的线程安全时,加锁方法就显得至关重要。这篇博客将探讨如何...

    程序员刷题哪个好-concurrent_map:GO中性能更好的线程安全映射

    ConcurrentMap GO 中性能更好的线程安全映射 在 v1.9 之后,通常程序员有两种线程安全映射的选择。 一种是使用syn.RWMutex 构建线程安全的解决方案。 但是,在很多情况下,尤其是在 CPU 核数大于 2 的情况下,该选项...

    TBB并发容器 学习笔记

    3. `concurrent_hash_map`:这是一个线程安全的哈希映射,允许并发的读写操作。它在多线程环境下提供高效的数据查找和更新,同时确保数据一致性。 相比于传统的STL容器,TBB并发容器的优势在于它们在设计时考虑了多...

    java并发工具包 java.util.concurrent中文版用户指南pdf

    10. 并发 Map(映射) ConcurrentMap 11. 并发导航映射 ConcurrentNavigableMap 12. 闭锁 CountDownLatch 13. 栅栏 CyclicBarrier 14. 交换机 Exchanger 15. 信号量 Semaphore 16. 执行器服务 ExecutorService 17. ...

    Java并发工具包java.util.concurrent用户指南中英文对照阅读版.pdf

    并发 Map(映射) ConcurrentMap 11. 并发导航 映射 ConcurrentNavigableMap 12. 闭锁 CountDownLatch 13. 栅栏 CyclicBarrier 14. 交换机 Exchanger 15. 信号量 Semaphore 16. 执行器服务 ExecutorService 17. ...

    python concurrent.futures 中文文档

    ### Python concurrent.futures 模块知识点详解 #### 1. Executor类 Executor是concurrent.futures模块中的一个抽象类,它定义了执行可调用对象的异步操作的方法。由于Executor本身是一个抽象类,因此不能直接使用...

    Python concurrent.futures模块使用实例

    线程和进程池API都是一样,所以应用只做最小的修改就可以在线程和进程之间地切换 1、基于线程池使用map() futures_thread_pool_map.py #!/usr/bin/env python # -*- coding: utf-8 -*- from co

    使用Java并发编程Concurrent Programming Using Java

    Java平台提供了丰富的API支持并发编程,如`java.util.concurrent`包下的各种类和接口,这些工具可以帮助开发者更高效地管理多线程环境下的任务调度和数据共享问题。 ### Java并发编程基础 #### 1. 多线程基础 - **...

    Java并发工具包java.util.concurrent用户指南中英文对照阅读版

    10. 并发 Map(映射) ConcurrentMap 11. 并发导航映射 ConcurrentNavigableMap 12. 闭锁 CountDownLatch 13. 栅栏 CyclicBarrier 14. 交换机 Exchanger 15. 信号量 Semaphore 16. 执行器服务 ExecutorService 17. ...

    python中map函数用法.docx

    结合Python的并发库,如`concurrent.futures`,`map()`函数可以用于实现并行计算。例如,使用`ThreadPoolExecutor`类执行多线程并行计算: ```python from concurrent.futures import ThreadPoolExecutor def ...

Global site tag (gtag.js) - Google Analytics