资讯专栏INFORMATION COLUMN

JCTools简介

YJNldm / 1167人阅读

摘要:序是一款对并发数据结构进行增强的并发工具,主要提供了以及的增强数据结构。只有几个方法对比主要是操作之后没有立即返回是对的增强,对多的支持以及高并发更新提供更好的性能。是对的简单包装以支持的接口。

JCTools是一款对jdk并发数据结构进行增强的并发工具,主要提供了map以及queue的增强数据结构。原来netty还是自己写的MpscLinkedQueueNode,后来新版本就换成使用JCTools的并发队列了。

增强map

ConcurrentAutoTable(后面几个map/set结构的基础)

NonBlockingHashMap

NonBlockingHashMapLong

NonBlockingHashSet

NonBlockingIdentityHashMap

NonBlockingSetInt

增强队列

SPSC - Single Producer Single Consumer (Wait Free, bounded and unbounded)

MPSC - Multi Producer Single Consumer (Lock less, bounded and unbounded)

SPMC - Single Producer Multi Consumer (Lock less, bounded)

MPMC - Multi Producer Multi Consumer (Lock less, bounded)

maven
        
            org.jctools
            jctools-core
            2.1.0
        
ConcurrentAutoTable

替代AtomicLong,专门为高性能的counter设计的。只有几个方法

public void add( long x );
public void decrement();
public void increment();
public void set( long x );
public long get();
public int  intValue();
public long longValue();
public long estimate_get();

对比AtomicLong主要是操作之后没有立即返回

public final long incrementAndGet();
public final long decrementAndGet()
NonBlockingHashMap

NonBlockingHashMap是对ConcurrentHashMap的增强,对多CPU的支持以及高并发更新提供更好的性能。
NonBlockingHashMapLong是key为Long型的NonBlockingHashMap。
NonBlockingHashSet是对NonBlockingHashMap的简单包装以支持set的接口。
NonBlockingIdentityHashMap是从NonBlockingHashMap改造来的,使用System.identityHashCode()来计算哈希
NonBlockingSetInt是一个使用CAS的简单的bit-vector

原来是

// --- hash ----------------------------------------------------------------
  // Helper function to spread lousy hashCodes.  Throws NPE for null Key, on
  // purpose - as the first place to conveniently toss the required NPE for a
  // null Key.
  private static final int hash(final Object key) {
    int h = key.hashCode();     // The real hashCode call
    h ^= (h>>>20) ^ (h>>>12);
    h ^= (h>>> 7) ^ (h>>> 4);
    h += h<<7; // smear low bits up high, for hashcodes that only differ by 1
    return h;
  }

改为

// --- hash ----------------------------------------------------------------
  // Helper function to spread lousy hashCodes
  private static final int hash(final Object key) {
    int h = System.identityHashCode(key); // The real hashCode call
    // I assume that System.identityHashCode is well implemented with a good
    // spreader, and a second bit-spreader is redundant.
    //h ^= (h>>>20) ^ (h>>>12);
    //h ^= (h>>> 7) ^ (h>>> 4);
    return h;
  }
doc

JCTools

Java Concurrent Counters By Numbers

Lock Free Queues Index

135 Million messages a second between processes in pure Java

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/70324.html

相关文章

  • 记JVM堆外内存泄漏Bug查找

    摘要:服务本身是一个,开起的线程数为,再加上一些其他线程,总的线程数不会超过服务内自己没有显示创建线程或者使用线程池。问题解决找到所在后,结局方案很简单,只需将的通过单例的方式注入到服务中,即可解决堆外内存泄漏的问题。 内存泄漏Bug现场 一个做BI数据展示的服务在一个晚上重启了5次,由于是通过k8s容器编排,服务挂了以后会自动重启,所以服务还能继续提供服务。 第一时间先上日志系统查看错误日...

    hiYoHoo 评论0 收藏0
  • 值得收藏!国外最佳互联网安全博客TOP 30

    摘要:最近有国外网站对多个互联网安全博客做了相关排名,小编整理其中排名前的安全博客,希望能给大家带来一些帮助。文章更新频率篇周地址简介谷歌在互联网安全的新闻和见解。其安全部分致力于分析最新的恶意软件威胁和漏洞。 如果你是网络安全从业人员,其中重要的工作便是了解安全行业的最新资讯以及技术趋势,那么浏览各大安全博客网站或许是信息来源最好的方法之一。最近有国外网站对50多个互联网安全博客做了相关排...

    mmy123456 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<