并发构建

向右看齐 2022-03-29 03:08 188阅读 0赞

同步容器：性能和复合操作问题，cme问题  
ConcurrentModificationException: 使用iterator时，其他线程修改容器，fail-fast,抛出此异常，导致我们需迭代过程加锁（可能导致性能问题）或克隆容器进行迭代，而且还有很多隐式的迭代（如sysout一个set）。  
并发容器：性能好，一般无cme  
ConcurrentHashMap 分段锁（任意线程读，一些线程写，读写可混合），迭代器容忍容器修改(弱一致的，已遍历过的修改反映不过来，对尚未遍历到的修改可以看到)，弱化了size，isEmpty等方法，取到非准确值，提供了多个复合原子操作  
CopyOnWriteArrayList 原理：对于正确发布的事实不可变对象无需同步访问，修改重新创建发布，迭代器保存了数组引用，永远在老的数组上迭代，不会cme，问题就是复制数组开销大  
阻塞队列和生产消费  
无界阻塞队列put永不阻塞  
阻塞队列的实现：  
LinkedBlockingQueue,ArrayBlockingQueue都是FIFO  
PriorityBlockingQueue 自然排序（Comparable）或Comparator 来确定优先级  
SynchronousQueue 不存储，维护一组线程，直接交付，put和take会阻塞到其他线程可以直接进行交付，即调用put阻塞，直到有线程调用take，调用take阻塞直到有线程调用put，队列模式take最先put的，栈模式take最后put的  
阻塞队列内部同步机制，保证对象从生产者线程安全发布到消费者线程：串行线程封闭，对象一直只能单个线程所有，原来是生产者线程，后来是某个消费者线程且原生产者线程不再访问它  
对象池：也是通过安全发布将对象借给某线程。  
Deque 两端插入和删除，工作密取，每个消费者有一个deque，自己消费完了可从其他deque**尾端**获取，避免了原生产消费模式下对共享队列的竞争。  
中断协作机制，请求而不是强制，可考虑抛出InterruptedException或保留中断状态，反正不能抹去被中断过的证据  
闭锁 等待某个事件（终止状态，到了终止状态就永远停在那了）  
CountDownLatch 等待计数器为零  
FutureTask 等待任务运行完成（等待运行，运行中，运行完成（正常完成，被取消CancellationException,抛出异常ExecutionException且cause包含原始的CheckedException或Rt或Error））  
信号量 控制同时访问的数量，实现有界容器等（add获取许可，若add失败释放许可，remove成功释放许可）  
栅栏 等待其他线程同时到达某个位置。  
CyclicBarrier await()超时或被中断，栅栏打破，其他线程的await()抛出BrokenBarrierException,成功通过栅栏重置等待下一次通过  
Exchanger 两方 V Exchanger.exchange(V)，一方线程先调用exchange方法，阻塞等待另一方线程调用此方法，然后两个线程交换对象，两对象被安全发布给了对方