java.util.concurrent.atomic.AtomicIntegerArray类提供了可以以原子方式读取和写入的底层int数组的操作，还包含高级原子操作。 AtomicIntegerArray支持对底层int数组变量的原子操作。 它具有获取和设置方法，如在变量上的读取和写入。 也就是说，一个集合与同一变量上的任何后续get相关联。 原子compareAndSet方法也具有这些内存一致性功能。序号方法描述1public int addAndGet(int i, int delta)原子地将给定的值添加到索引i的元...
Java并发编程之验证volatile不能保证原子性通过系列文章的学习，凯哥已经介绍了volatile的三大特性。1：保证可见性 2：不保证原子性 3：保证顺序。那么怎么来验证可见性呢？本文凯哥(凯哥Java:kaigejava)将通过代码演示来证明为什么说volatile不能够保证共享变量的原子性操作。我们来举个现实生活中的例子：中午去食堂打饭，假设你非常非常的饥饿，需要一荤两素再加一份米饭。如果食堂打饭的阿姨再给你打一个菜的时候，被其他人打断...
「 盛年不重来,一日难再晨,及时当勉励,岁月不待人。」 陶渊明我们已经知道同步代码块和同步方法可以保证以原子的方式执行，其实，同步还有另外一个重要概念：内存可见性。换句话说，我们不仅希望防止某个线程正在使用对象状态而另一个线程同时在修改状态，而且希望确保当一个线程修改了对象的状态后，其他线程能够看到修改后的状态。可见性一个线程对共享变量值的修改，能够及时的被其他线程看到。可见性微妙的，这是因为可能发生...
作用CyclicBarrier是一个同步辅助类，它允许一组线程互相等待，直到到达某个公共屏障点 (common barrier point)，才继续执行。简介CyclicBarrier 的字面意思是可循环使用（Cyclic）的屏障（Barrier）。它要做的事情是，让一组线程到达一个屏障（也可以叫同步点）时被阻塞，直到最后一个线程到达屏障时，屏障才会开门，所有被屏障拦截的线程才会继续干活。CyclicBarrier默认的构造方法是CyclicBarrier(int parties)，其参数表示屏障...
线程的状态线程从创建到最终的消亡，要经历若干个状态。一般来说，线程包括以下这几个状态：创建(new)、就绪(runnable)、运行(running)、阻塞(blocked)、time waiting、waiting、消亡（dead）。 当需要新起一个线程来执行某个子任务时，就创建了一个线程。但是线程创建之后，不会立即进入就绪状态，因为线程的运行需要一些条件（比如内存资源，在前面的JVM内存区域划分一篇博文中知道程序计数器、Java栈、本地方法栈都是线程私有的...
Java并发编程之CAS二源码追根溯源在上一篇文章中，我们知道了什么是CAS以及CAS的执行流程，在本篇文章中，我们将跟着源码一步一步的查看CAS最底层实现原理。本篇是《凯哥(凯哥Java:kagejava)并发编程学习》系列之《CAS系列》教程的第二篇：从源码追根溯源查看CAS最底层是怎么实现的。本文主要内容：CAS追根溯源，彻底找到CAS的根在哪里。一：查看AtomicInteger.compareAndSet源码通过上一篇文章学习，我们知道了AtomicInteger.comp...
ReentrantLock是一个较为常用的锁对象。在上次分析的uil开源项目中也多次被用到，下面谈谈其概念和基本使用。概念一个可重入的互斥锁定 Lock，它具有与使用 synchronized 相同的一些基本行为和语义，但功能更强大。名词解释：互斥表示同一时刻，多个线程中，只能有一个线程能获得该锁。但是多个线程都可以调用lock方法，只有一个会成功，其他的线程会被阻塞，直到该锁被释放可重入模仿synchronized 的语义；如果线程进入由线程已经...
转载请标明出处：http://blog.csdn.net/lmj623565791/article/details/27250059一般情况下，我们使用Runnable作为基本的任务表示形式，但是Runnable是一种有很大局限的抽象，run方法中只能记录日志，打印，或者把数据汇总入某个容器（一方面内存消耗大，另一方面需要控制同步，效率很大的限制），总之不能返回执行的结果；比如同时1000个任务去网络上抓取数据，然后将抓取到的数据进行处理（处理方式不定），我觉得最好的方式就是提...
Java并发编程：Lock 在上一篇文章中我们讲到了如何使用关键字synchronized来实现同步访问。本文我们继续来探讨这个问题，从Java 5之后，在java.util.concurrent.locks包下提供了另外一种方式来实现同步访问，那就是Lock。 也许有朋友会问，既然都可以通过synchronized来实现同步访问了，那么为什么还需要提供Lock？这个问题将在下面进行阐述。本文先从synchronized的缺陷讲起，然后再讲述java.util.concurrent.locks包下常用...
后台线程提供一种通用的线程服务，这个线程并不属于程序中不可或缺的部分。所以，当所有的非后台线程结束时，程序也就终止了，同时也杀死了所有的后台线程。所以后台线程不一定会运行完。import java.util.concurrent.TimeUnit; /*** 后台线程* @author Administrator**/publicclass DaemonDemo implements Runnable {@Overridepublicvoid run() {try {while (true) {TimeUnit.MILLISECONDS.sleep(100);// 线程sleepSystem.out.pri...
JDK5中添加了新的concurrent包，相对同步容器而言，并发容器通过一些机制改进了并发性能。因为同步容器将所有对容器状态的访问都串行化了，这样保证了线程的安全性，所以这种方法的代价就是严重降低了并发性，当多个线程竞争容器时，吞吐量严重降低。因此Java5.0开始针对多线程并发访问设计，提供了并发性能较好的并发容器，引入了java.util.concurrent包。与Vector和Hashtable、Collections.synchronizedXxx()同步容器等相比，uti...
在学习锁优化时，对象头(Mark Word) 是必不可缺的一环，因为synchronized 用的锁是存在对象头里的。32位的虚拟机上对象头占64位（8字节），64位的虚拟机上对象头占128位(16字节）[^objectHead]；而不同的类型，对象头的布局不太一样：数组类型：Mark Word、Class Metadata Address、Array Length普通类型：Mark Word、Class Metadata AddressMark Word 表示对象的HashCode 或 锁信息Class Metadata Address 表示对象的数据类型在方...
本文讲ArrayBlockingQueue1. 介绍一个基于数组的有界阻塞队列，FIFO顺序。支持等待消费者和生产者线程的可选公平策略(默认是非公平的)。公平的话通常会降低吞吐量，但是可以减少可变性并避免之前被阻塞的线程饥饿。1.1 类结构ArrayBlockingQueue继承关系ArrayBlockingQueue类图构造器 // 默认是非公平的public ArrayBlockingQueue(int capacity) {this(capacity, false);}public ArrayBlockingQueue(int capacity, boolean fair...
CountDownLatch，一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。 用给定的计数 初始化 CountDownLatch。由于调用了 countDown() 方法，所以在当前计数到达零之前，await 方法会一直受阻塞。之后，会释放所有等待的线程，await 的所有后续调用都将立即返回。这种现象只出现一次——计数无法被重置。如果需要重置计数，请考虑使用 CyclicBarrier。 CountDownLatch 是一个通用同步工具，它...
目录 一、入门示例 二、异常场景1 三、异常场景2 四、解决方法 之前在使用线程池的时候，出现了 java.util.concurrent.RejectedExecutionException ，原因是线程池配置不合理，导致提交的任务来不及处理。接下来用一个简单的例子来复现异常。Exception in thread "main" java.util.concurrent.RejectedExecutionException: Task org.cellphone.common.pool.Worker@f6f4d33 rejected from java.util.concurrent.ThreadP...