深度剖析Java高并发：从线程池到CAS原理，阿里面试必问系列

引言

高并发是Java后端开发的核心能力，也是大厂面试的重灾区。本文将从线程池核心原理、CAS无锁机制、Synchronized优化、JUC并发工具类四个维度，深入剖析Java高并发的底层逻辑。

一、线程池核心原理

1.1 线程池为什么要用

直接创建线程的问题：

// 每次请求都创建新线程for(inti=0;i<1000;i++){newThread(()->{// 业务逻辑}).start();}

问题：

• 线程创建和销毁开销大
• 大量线程竞争CPU资源
• 线程数量不可控

1.2 线程池工作原理

// 线程池核心参数publicThreadPoolExecutor(intcorePoolSize,// 核心线程数intmaximumPoolSize,// 最大线程数longkeepAliveTime,// 空闲线程存活时间TimeUnitunit,// 时间单位BlockingQueue<Runnable>workQueue,// 任务队列ThreadFactorythreadFactory,// 线程工厂RejectedExecutionHandlerhandler// 拒绝策略)

线程池执行流程：

任务进来 ↓ corePoolSize未满？→ 创建核心线程执行 ↓ (是) 核心线程满了吗？ ↓ (否) workQueue未满？→ 任务加入队列等待 ↓ (是) maximumPoolSize未满？→ 创建临时线程执行 ↓ (是) 执行拒绝策略

1.3 七大参数详解

1.4 阿里面试题：线程池大小怎么设置？

// CPU密集型任务intcorePoolSize=Runtime.getRuntime().availableProcessors()+1;// IO密集型任务（经验公式）intcorePoolSize=Runtime.getRuntime().availableProcessors()*2;// 或者更精确的计算intcorePoolSize=Runtime.getRuntime().availableProcessors()/(1-阻塞系数)// 阻塞系数通常取0.8~0.9

二、CAS无锁机制

2.1 CAS是什么

CAS（Compare And Swap）是一种无锁算法，它包含三个操作数：

• 内存位置 V
• 预期原值 A
• 新值 B

// CAS语义：只有当V的值等于A时，才用B去更新V// 否则什么都不做，返回V当前值

2.2 Java中CAS的实现

// AtomicInteger源码分析publicclassAtomicIntegerextendsNumber{privatestaticfinallongserialVersionUID=...;// 使用Unsafe类的CAS操作privatevolatileintvalue;publicfinalbooleancompareAndSwap(intexpectedValue,intnewValue){returnunsafe.compareAndSwapInt(this,valueOffset,expectedValue,newValue);}// 乐观锁实现publicfinalintincrementAndGet(){for(;;){intcurrent=get();intnext=current+1;if(compareAndSwap(current,next)){returnnext;}}}}

2.3 CAS的三大问题

问题1：ABA问题

// 线程1读取A，线程2将A改成B又改回A，线程1的CAS仍会成功// 解决：使用AtomicStampedReference增加版本号AtomicStampedReference<Integer>ref=newAtomicStampedReference<>(1,0);ref.compareAndSet(1,2,0,1);// 带版本号的CAS

问题2：自旋开销大

// 如果CAS失败，会一直自旋，消耗CPU// 解决：限制自旋次数，或使用LongAdderLongAddercounter=newLongAdder();counter.increment();// 分散热点，优于AtomicLong

问题3：只能保证一个变量原子性

// 多个变量需要原子操作怎么办？// 解决：使用AtomicReferenceAtomicReference<User>userRef=newAtomicReference<>();userRef.compareAndSet(oldUser,newUser);

三、Synchronized优化

3.1 synchronized锁升级路径

无锁 → 偏向锁 → 轻量级锁 → 重量级锁

3.2 锁消除

publicvoidmethod(){// JIT编译时发现这个StringBuffer不会逃逸出方法外// 消除synchronized，直接拼接StringBuffersb=newStringBuffer();sb.append("a").append("b");// 实际上没有锁的开销}

3.3 锁粗化

// 连续加锁操作JIT会合并StringBuffersb=newStringBuffer();synchronized(sb){sb.append("a");}synchronized(sb){sb.append("b");}// JIT优化为：synchronized(sb){sb.append("a");sb.append("b");}

四、JUC并发工具类

4.1 CountDownLatch门闩

// 场景：等待多个线程执行完毕再执行主线程CountDownLatchlatch=newCountDownLatch(3);newThread(()->{// 任务1latch.countDown();}).start();newThread(()->{// 任务2latch.countDown();}).start();latch.await();// 阻塞直到countDown()被调用3次System.out.println("所有任务完成");

4.2 CyclicBarrier循环栅栏

// 场景：多个线程互相等待，全部到达后再执行CyclicBarrierbarrier=newCyclicBarrier(3,()->{System.out.println("所有人都到了，开始执行任务");});for(inti=0;i<3;i++){newThread(()->{// 准备任务barrier.await();// 等待其他人// 执行任务}).start();}

4.3 Semaphore信号量

// 场景：控制同时访问资源的线程数Semaphoresemaphore=newSemaphore(3);for(inti=0;i<10;i++){newThread(()->{try{semaphore.acquire();// 获取许可证// 访问共享资源（数据库连接池等）semaphore.release();// 释放许可证}catch(InterruptedExceptione){e.printStackTrace();}}).start();}

总结

核心口诀：线程池控资源，CAS乐观无阻塞，Synchronized看升级，JUC工具解并发。