《java并发编程的艺术》note

骑猪看日落 2022-06-01 12:49 236阅读 0赞

关于内存模型，并发包的底层实现仍需研究。

## 6.java并发容器和框架 ##

6.1ConcurrentHashMap  
6.2ConcurrentLinkedQueue 同步队列  
6.3java中的阻塞队列 插满等，移空空  
6.4Fork/Join框架 切分小任务

## 7.java中13个原子操作类 ##

原子更新基本类型类：
         AtomicBoolean
         AtomicInteger
         AtomicLong
      原子更新数组
          AtomicIntegerArray
          AtomicLongArray
          AtomicReferenceArray
          AtomicIntegerArray
      原子更新引用类型
         AtomicReference
         AtomicReferenceFieldUpdater
         AtomicMarkableReference
      原子更新字段类
      AtomicIntegerFieldUpdater
      AtomicLongFieldUpdater
      AtomicStampedReference

## 8.JAVA的并发工具类 ##

**8.1 CountDownLatch**  
希望主线程等待多个线程都执行完，主线程才继续执行。  
await()会阻塞当前线程，直到N减到0。如不希望主线程一直等待，用await(long time,TimeUnit unit)。  
多线程时，只需把CountDownLatch的引用传递到线程里。  
**8.2CyclicBarrier**  
同步屏障，每个线程调用await()告诉Cyclic已到达屏障，挡够数目，开闸  
可以new CyclicBarrier()的同时 指定开闸后优先执行的线程（此线程不必是被挡的。如多个sheet计算线程，都来齐时优先执行汇总线程  
**8.3CyclicBarrier和 CountDownLatch区别**  
CyclicBarrier比较强大，适用于复杂业务，比如计算出错可以重设计数器。查看被挡线程数目，挡住的线程是否中断  
**8.4Semaphore**  
Semaphore用来控制同时并发访问资源的线程数量(限流）  
**8.5Exchanger**  
用于线程间交换数据  
比如A/B分别计算，可以校对

## 9.java中的线程池 ##

**9.1核心池–队列–线程池–饱和策略**  
**9.2**  
new ThreadPoolExecutor(corepoolsize,maximumpoolsize,keepAliveTime,milliseconds,runnableTaskQueue,handler)  
**9.3 threadPool.execute()提交不需返回值的任务**  
**9.4关闭线程池**  
.shutdown() .shutdownNow（）  
只要调用其一，则isShutdown()为true,但所有任务结束，isTeminated()才是true  
不一定任务要执行完可用shutdownNow()  
建议不要用无界队列

## 10.Executor框架 ##

Executor框架便是Java 5中引入的，其内部使用了线程池机制，它在java.util.cocurrent 包下，通过该框架来控制线程的启动、执行和关闭，可以简化并发编程的操作。因此，在Java 5之后，通过Executor来启动线程比使用Thread的start方法更好，除了更易管理，效率更好.  
**10.1Executor简介**  
结构：任务，任务执行，异步计算结果  
成员:  
1.ThreadPoolExecutor  
2.ScheduledThreadPoolExecutor  
3.Future接口  
4.Runnable接口和Callable接口  
**10.2ThreadPoolExecutor详解**

FixedThreadPool
    SingleThreadExecutor
    CachedThreadPool

**10.3 ScheduledThreadPoolExecutor**  
主要用来给定时间和延迟时间的任务，定期任务等  
1.4Future的实现类FutureTask

**高并发抢红包项目**：总红包表，记录用户红包表  
**bug版**：前端传入用户id与红包id，请求controller,查询剩余红包>0则总红包表-1，插入用户红包表记录。因为查询没锁，所以出现红包数减到负的情况。  
**悲观锁版**：查询语句加for update则查询加上悲观锁，只能等一个线程搞完提交事务下一线程才能拿到锁继续，性能问题  
**乐观锁版**：先取版本号，update总红包表剩余红包时加上版本号（cas)，版本一致才成功。否则重入，重入可用代码控制，三次，不断轮询etc。