java.util.concurrent  JUC

集合
ConcurrentHashMap
ConcurrentSkipListMap
基于跳跃表，key 自然排序，key 不能为 null，类似 TreeMap
volatile+CAS  

ConcurrentSkipListSet  基于 ConcurrentSkipListMap 实现

CopyOnWriteArrayList
基于数组实现  数组初始长度为0
写时复制 CopyOnWrite COW

private transient volatile Object[] array;
public boolean add(E e) {
// 更新加锁 
final ReentrantLock lock = this.lock;
    lock.lock();
    try {
        Object[] elements = getArray();
        int len = elements.length;
        // 拷贝新数组，长度+1
        Object[] newElements = Arrays.copyOf(elements, len + 1);
        newElements[len] = e; 
        //  volatile  数组替换
        setArray(newElements);
        return true;
  } finally {
        lock.unlock();
    }
}



CopyOnWriteArraySet
基于 CopyOnWriteArrayList 实现 ，去重，按照插入顺序排序



非阻塞队列
ConcurrentLinkedQueue
基于链表 无界的线程安全的非阻塞队列 ，FIFO  volatile+CAS


private static class Node<E> {
    volatile E item;
    volatile Node<E> next;
}
private transient volatile Node<E> head;
private transient volatile Node<E> tail;

private boolean casTail(Node<E> cmp, Node<E> val) {
    return UNSAFE.compareAndSwapObject(this, tailOffset, cmp, val);
}

private boolean casHead(Node<E> cmp, Node<E> val) {
    return UNSAFE.compareAndSwapObject(this, headOffset, cmp, val);
}




ConcurrentLinkedDeque
双向链表 实现与 ConcurrentLinkedQueue 类似


static final class Node<E> {
    volatile Node<E> prev;
    volatile E item;
    volatile Node<E> next;
}





阻塞队列

ReentrantLock   Condition  通知等待

ArrayBlockingQueue
LinkedBlockingQueue
PriorityBlockingQueue   
优先队列 基于二叉小顶堆  保证取出的元素是最小的，默认初始容量11

DelayQueue
基于数组实现 延迟阻塞队列
Delayed 接口

public interface Delayed extends Comparable<Delayed> {
    long getDelay(TimeUnit unit);
}






原子类

AtomicInteger
AtomicLong
AtomicReference



并发工具类

CountDownLatch

CyclicBarrier
支持 reset() 重置状态
ReentrantLock  Condition
 
 


线程池

ThreadPoolExecutor
核心参数


public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory,
                              RejectedExecutionHandler handler)


核心线程数
最大线程数
线程空闲时间
线程空闲时间单位
任务队列
线程工厂  定制线程名 方便排查问题
决绝策略

CallerRunsPolicy 
AbortPolicy 
DiscardPolicy 
DiscardOldestPolicy 


 基于 ReentrantLock Condition await signalAll 实现简单的阻塞队列 
 基于 wait 和 notifyAll 实现简单的阻塞队列 
 ReentrantLock原理 
 LockSupport简介 
 java线程状态及转换 
Lock和synchronized的区别
java并发机制的底层实现原理
ArrayBlockingQueue和LinkedBlockingQueue的区别
ConcurrentHashMap在jdk7和8中的区别
并发机制的底层实现原理摘要
AQS同步队列与条件队列
公平锁与非公平锁的关键区别
java8 ConcurrentHashMap 锁机制
线程池要点
java线程池实例 
java线程池shutdown和shutdownNow的区别
ThreadPoolExecutor中的ctl变量
tomcat线程池要点
Java线程池ExecutorService与CompletionService
Timer和ScheduledExecutorService的区别
Java锁机制
threadlocal实例及原理
LongAdder vs AtomicLong
CountDownLatch 与 CyclicBarrier  
ConcurrentHashMap读操作为什么不需要加锁
ThreadLocal 与 SimpleDateFormat 
java关键字volatile原理
延迟队列原理及使用场景
java中的队列介绍
AQS要点整理
The java.util.concurrent Synchronizer Framework 翻译