Java 8 LongAdders:管理并发计数器的正确方式

转自:http://www.importnew.com/11345.html

我只是喜欢新鲜的事物,而Java 8 有很多新东西。这次我想讨论其中我最喜欢的之一:并发加法器。这是一个新的类集合,他们用来管理被多线程读写的计数器。这个新的API在显著提升性能同时,仍然保持了简单直接的特点。

多核架构到来之后人们就解决着并发计数器,让我们来看看到现在为止Java提供了哪些解决并发计数器的选项,并对比一下他们与新API的性能。

脏计数器 – 这种方法意味着一个常规对象或静态属性正在被多线程读写。不幸的是,由于两个原因这行不通。原因之一,在Java中A += B操作不是原子的。如果你打开输出字节码,你将至少看到四个指令 —— 第一个用来将属性值从堆加载到线程栈,第二个用来加载delta,第三个用来把它们相加,第四个用来将结果重新分配给属性值。

如果多个线程同时作用于同一块内存单元,写操作有很大机会丢失,因为一个线程可以覆盖另一个线程的值(又名“读-修改-写”),另一个令人不快的是这种情况下你不得不处理值的冲突,还有更坏的情况。

这是相当菜鸟的一个问题,而且超级难调试。如果你确实发现有人在你的应用中这么做的话,我想要你帮个小忙。在你的数据库中搜索“Tal Weiss”,如果存在我的记录,请删除,这样我会觉得安全些。

Synchronized – 最基本的并发用语,它在读写一个值的时候会阻塞所有想读写该值的其他线程。虽然它是可行的,但你的代码却注定要被转向DMV line

读写锁 – 基本Java锁的略复杂版本,它使你能够区分修改值并且需要阻塞其他线程的线程和仅是读取值并且不需要临界区的线程。虽然这更有效率(假设写线程数量很 少),但由于当你获取写锁的时候阻塞了所有其他线程的执行,这真是一个“漂亮”的方法。事实上,只有当你了解到相比读线程,写线程的数量极大地受限时它才 真正是一个好方法。

Volatile – 这个关键词非常容易被误解,它指示JIT编译器重新优化运行时机器码,使得属性的任何修改对其他线程都是即时可见的。

这将导致一些JIT处理内存分配的顺序这项JIT编译器最喜爱的优化失效。你再说一遍?是的,你没有听错。JIT编译器可以改变属性分配的顺序。这个神秘的小策略(又叫happens-before)能够最小化程序访问全局堆的次数,同时仍然确保你的代码没有被影响。真是相当隐蔽…

所以什么时候应该使用volatile处理计数器呢?如果你仅有一个线程更新值并且多个线程读取它,这时使用volatile无疑是一个真正好的策略。

那为什么不总是使用它呢?因为当多个线程同时更新属性的时候它不能很好的工作。由于A += B不是原子操作,这将带来覆盖其他写操作的风险。在Java8之前,处理这种情况你需要使用的是AtomicInteger。

AtomicInteger – 这组类使用CAS(比较并交换)处理器指令来更新计数器的值。听起来不错,真的是这样吗?是也不是。好的一面是它通过一个直接机器码指令设置值时,能够最 小程度地影响其他线程的执行。坏的一面是如果它在与其他线程竞争设置值时失败了,它不得不再次尝试。在高竞争下,这将转化为一个自旋锁,线程不得不持续尝 试设置值,无限循环直到成功。这可不是我们想要的方法。让我们进入Java 8的LongAdders。

Java 8 加法器 – 这是一个如此酷的新API以至于我一直在滔滔不绝地谈论它。从使用的角度看它与AtomicInteger非常相似,简单地创建一个LongAdder实例,并使用intValue()和add()来获取和设置值。神奇的地方发生在幕后。

这个类所做的事情是当一个直接CAS由于竞争失败时,它将delta保存在为该线程分配的一个内部单元对象中,然后当intValue()被调用时,它会将这些临时单元的值再相加到结果和中。这就减少了返回重新CAS或者阻塞其他线程的必要。多么聪明的做法!

好吧,已经说的够多了-让我们看看这个类的实际表现吧。我们设立了下面的基准测试-通过多线程将一个计数器增加到10^8。我们用总共10个线程来运行这个测试-5个写操作,5个读操作。测试机器仅有一个四核的i7处理器,因此测试一定会产生一些严重的竞争:

代码这里可以下载到

注意dirty和volatile都冒着一些严重的值覆盖危险。

总结

  • 并行加法器相比原子整数拥有60%-100%的性能提升
  • 执行加法的线程之间没有太大差别,除非被锁定
  • 注意当你使用synchronized或读写锁时所带来的巨大性能问题 – 慢一个甚至两个数量级

我非常愿意听到-你已经有机会在你的代码中使用这些类了。

时间: 2024-12-17 01:32:02

Java 8 LongAdders:管理并发计数器的正确方式的相关文章

JAVA当中内存管理与垃圾回收!

很多Java面试的时候,都会问到有关Java垃圾回收的问题,提到垃圾回收肯定要涉及到JVM内存管理机制,Java语言的执行效率一直被C.C++程序员所嘲笑,其实,事实就是这样,Java在执行效率方面确实很低,一方面,Java语言采用面向对象思想,这也决定了其必然是开发效率高,执行效率低.另一方面,Java语言对程序员做了一个美好的承诺:程序员无需去管理内存,因为JVM有垃圾回收(GC),会去自动进行垃圾回收. 其实不然: 1.垃圾回收并不会按照程序员的要求,随时进行GC. 2.垃圾回收并不会及时

Java系列笔记(6) - 并发(上)

目录 1,基本概念 2,volatile 3,atom 4,ThreadLocal 5,CountDownLatch和CyclicBarrier 6,信号量 7,Condition 8,Exchanger 在Java中,JVM.并发.容器.IO/NIO是我认为最重要的知识点,本章将介绍其中的并发,这也是从“会Java”到精通Java所必须经历的一步.本章承接上一张<Java系列笔记(5) - 线程>,其中介绍了Java线程的相关知识,是本章介绍内容的基础,如果对于线程不熟悉的,可以先阅读以下这

Java自动内存管理机制学习(一):Java内存区域与内存溢出异常

备注:本文引用自<深入理解Java虚拟机第二版> 2.1 运行时数据区域 Java虚拟机在执行Java程序的过程中把它所管理的内存划分为若干个不同的数据区域.这些区域都有各自的用途,以及创建和销毁的时间,有的区域随着虚拟机进程的启动而存在,有些区域则依赖用户线程的启动和结束而建立和销毁.如下图所示: 2.1.1 程序计数器 程序计数器是一块较小的内存空间,它是线程的私有内存,可以看作时当前线程所执行的字节码的行号指示器.在虚拟机的概念模型里(仅是概念模型,各种虚拟机可能会通过一些更高效的方式去

Java 面试宝典!并发编程 71 道题及答案全送上!

金九银十跳槽季已经开始,作为 Java 开发者你开始刷面试题了吗?别急,我整理了71道并发相关的面试题,看这一文就够了! 1.在java中守护线程和本地线程区别? java中的线程分为两种:守护线程(Daemon)和用户线程(User). 任何线程都可以设置为守护线程和用户线程,通过方法Thread.setDaemon(bool on):true则把该线程设置为守护线程,反之则为用户线程.Thread.setDaemon()必须在Thread.start()之前调用,否则运行时会抛出异常. 两者

java自动内存管理机制

java程序员把内存管理的工作交给虚拟机,一旦出现内存泄露或者溢出问题,如果不了解内存是怎样工作的,那么排查错误将是一件异常艰难的工作. java内存区域与内存溢出异常 java运行时数据区域划分: 线程隔离的 1.程序计数器(Program Counter Register) 当前线程执行代码的行号指示器,当线程切换并分配处理器执行时间,为了保证线程恢复到正确的执行位置,每个线程都有独立的计数器 2.虚拟机栈(VM Stack) 虚拟机栈描述的是java方法执行的内存模型:每个方式执行的同时会

十分良心!全网最详细的Java 自动内存管理机制及性能优化教程

同样的,先来个思维导图预览一下本文结构. 一图带你看完本文 一.运行时数据区域 首先来看看Java虚拟机所管理的内存包括哪些区域,就像我们要了解一个房子,我们得先知道这个房子大体构造.根据<Java虚拟机规范(Java SE 7 版)>的规定,请看下图: Java 虚拟机运行时数据区 1.1 程序计数器 程序计数器是一块较小的内存空间,它可以看作是当前线程所执行的字节码的行号指示器. 由于 Java 虚拟机的多线程是通过线程轮流切换并分配处理器执行时间的方式来实现的,在任何一个确定的时刻,一个

Java中不同的并发实现的性能比较

Fork/Join框架在不同配置下的表现如何? Java 8的并行流也是毁誉参半.并行流(Parallel Stream)的语法糖令人兴奋不已.现在Java中实现并发编程存在多种方式,我们希望了解这么做所带来的性能提升及风险是什么.从经过260多次测试之后拿到的数据来看,还是增加了不少新的见解的,这里我们想和大家分享一下. ExecutorService vs. Fork/Join框架 vs. 并行流 在10年前,Java的并发还只能通过第三方库来实现.然后Java 5到来了,并引入了java.

Java虚拟机内存管理机制

自动内存管理机制 Java虚拟机(JVM)在执行Java程序过程中会把它所管理的内存划分为若干个不同的数据区域.这些区域都有各自的用途,以及创建和销毁的时间,有的区域随着虚拟机进程的启动而存在,有的区域则是依赖用户线程的启动和结束而建立和销毁.根据<Java虚拟机规范 第2版>规定,运行时数据区包括: 1.程序计数器 一块较小的内存空间,不在Ram上,而是直接划分在CPU上的,程序员无法直接操作它.当前线程所执行的字节码的行号指示器,通过改变这个计数器的值来选取下一条需要执行的字节码指令.每条

Java是如何管理内存的?

本文转自CSDN用户Kevin涂腾飞的文章java内存管理机制:http://blog.csdn.net/tutngfei1129287460/article/details/7383480 JAVA 内存管理总结 1. java是如何管理内存的 Java的内存管理就是对象的分配和释放问题.(两部分) 分配 :内存的分配是由程序完成的,程序员需要通过关键字new 为每个对象申请内存空间 (基本类型除外),所有的对象都在堆 (Heap)中分配空间. 释放 :对象的释放是由垃圾回收机制决定和执行的,