多线程 - 召田最帅boy

如何实现线程复用？

线程池通过维护 Worker 对象实现复用。execute 先在核心线程数范围内尝试 addWorker 创建线程，若达上限则把任务放入 workQueue。Worker 持有 Thread 并实现 Runnable，其 run 方法调用 runWorker。runWorker 在循环中先执行 firstTask，再不断从队列获取任务并执行 task.run()；run 本身不再创建新线程，线程始终在同一 Thread 上循环处理任务直至关闭。于是同一线程被重复利用，完成线程复用的核心机制。

2021-11-10 10:30:33 阅读

AQS源码分析

AQS（AbstractQueuedSynchronizer）通过一个 volatile int state 和基于 CLH 双向链表的等待队列实现同步。它支持独占和共享两种模式，核心接口为 acquire/release 和 acquireShared/releaseShared，内部采用模板方法模式，分别调用子类实现的 tryAcquire、tryRelease、tryAcquireShared、tryReleaseShared。Node 类保存线程、前后指针、waitStatus 等信息，waitStatus 包含 CANCELLED、SIGNAL、CONDITION、PROPAGATE 等状态。文中示例了基于 AQS 的独占锁 Mutex，实现了 lock、unlock、tryLock、Condition 等功能，并详细剖析了 acquire、addWaiter、enq 等关键源码，说明线程如何封装为 Node、通过 CAS 加入队尾、以及在自旋失败时进入等待队列直至获取资源。

2021-11-03 20:22:41 阅读