用途:在 Java 代码中识别并应用并发最佳实践,改善线程安全、可扩展性与可维护性,使用现代 java.util.concurrent 工具与虚拟线程。
主要能力:线程安全基础(ConcurrentHashMap、AtomicInteger、ReentrantLock、ReadWriteLock、Java 内存模型);ExecutorService 线程池配置(大小、keep-alive、有界队列、拒绝策略、优雅关闭);基于 BlockingQueue 的生产者-消费者与发布-订阅模式;CompletableFuture 非阻塞异步组合(thenApply/thenCompose/exceptionally/orTimeout);不可变性与安全发布(volatile、静态初始化);锁竞争与伪共享性能优化;虚拟线程(Executors.newVirtualThreadPerTaskExecutor())用于 I/O 密集型扩展;结构化并发(StructuredTaskScope,Java 27 预览);用 ScopedValue 替代 ThreadLocal;协作式取消与 InterruptedException 规范;有界队列与 CallerRunsPolicy 背压;通过全局锁顺序与带超时 tryLock 避免死锁;ForkJoin/并行流用于 CPU 密集型;虚拟线程 pinning 检测(JFR VirtualThreadPinned);线程命名与 UncaughtExceptionHandler 可观测性;适用原语(LongAdder、CopyOnWriteArrayList、StampedLock、Semaphore、CountDownLatch、Phaser)。
使用方式:应用前先运行 ./mvnw compile 或 mvn compile,编译失败须立即停止;阅读 references/125-java-concurrency.md 分析热点;应用改进后运行 ./mvnw clean verify 或 mvn clean verify 完整验证。
适用场景:审查 Java 并发与线程安全代码、修复竞态条件、选择 ExecutorService 或虚拟线程、改进同步与共享可变状态、对相关子任务应用结构化并发。
限制:参考按示例组织,需按适用示例应用建议;编译失败为阻塞条件;具体版本与预览特性以资料为准,其余细节暂未提供。