本书主要介绍基于Java的并行程序设计基础、思路、方法和实战。首先，立足于并发程序基础，详细介绍Java中进行并行程序设计的基本方法。其次，进一步详细介绍了JDK中对并行程序的强大支持，帮助读者可以快速、稳健地进行并行程序开发。再次，详细讨论了有关"锁”的优化和提高并行程序性能级别的方法和思路。第四，介绍了并行的基本设计模式以及Java 8、9、10对并行程序的支持和改进。第五，介绍了高并发框架Akka的使用方法。第六，详细介绍了并行程序的调试方法。最后分析Jetty代码并给出一些其在高并发优化方面的举例。《实战java高并发程序设计》第1~2版得到了读者的认可，而今Java 版本一直在变化，新的技术也有迭代，本书更要与时俱进，进行一些深层技术的更新，如GC一些优化方式等等。

前　　言 关于Java与并行 由于单核CPU的主频逐步逼近极限，多核CPU架构成了一种必然的技术趋势，因此多线程并行程序便显得越来越重要。并行计算的一个重要应用场景就是服务端编程。目前服务端CPU的核心数已经轻松超越10个，而Java显然是当下最流行的服务端编程语言，且已经更新到JDK 14，因此熟悉和了解基于Java的并行程序开发有着重要的实用价值。 本书的体系结构 本书立足于实际开发，但不缺乏理论介绍，力求通俗易懂、循序渐进。本书共分为9章。 第1章主要介绍并行计算中的一些基本概念，让读者对并行计算有一个基本认识，其中包括两个重要的并行性能评估定律，以及Java内存模型JMM。 第2章介绍Java并行程序开发的基础，包括Java中线程的基本使用方法等，也详细介绍了并行程序容易引发的一些错误，以及容易出现的误用。 第3章介绍JDK内部对并行程序开发的支持，主要介绍JUC（java.util.concurrent）中一些工具的使用方法、各自的特点及它们的内部实现原理。 第4章介绍在开发过程中可以进行的对锁的优化，也进一步简要描述了Java虚拟机层面对并行程序的优化和支持。此外，还花了一定的篇幅介绍无锁的计算。 第5章介绍并行程序设计中常见的一些设计模式，以及典型的并行算法和使用方法，其中包括重要的Java NIO和AIO的介绍。 第6章介绍Java 8/9/10为并行计算所做的改进，包括并行流、CompletableFuture、StampedLock、LongAdder，以及发布和订阅模式等。 第7章主要介绍高并发框架Akka的基本使用方法，并使用Akka框架实现了一个简单的粒子群算法，模拟超高并发的场景。 第8章介绍使用Eclipse进行多线程调试的方法，并演示了通过Eclipse进行多线程调试来重现ArrayList的线程不安全问题。 第9章介绍Jetty，并分析Jetty的关键代码，主要展示它在高并发优化中所做的一些努力，也为读者学会并深入理解高并发提供一些提示和思考。 本书特色 本书的主要特色如下。 1. 结构清晰。本书一共9章，总体上循序渐进、逐步提升。每一章都有鲜明的侧重点，有利于读者快速抓住重点。 2. 理论结合实战。本书注重实战，书中重要的知识点都安排了代码实例，从而利于读者理解，同时对系统的内部实现原理进行了深度剖析。 3. 通俗易懂。本书尽量避免采用过于理论化的描述方式，简单的白话文风格贯穿全书，配图基本上为手工绘制示意图，降低了理解难度，并尽量做到让读者在阅读过程中少盲点、无盲点。 适合阅读人群 虽然本书力求通俗，但是要通读本书并取得良好的学习效果，仍要求读者具备基本的Java知识或者一定的编程经验。因此，本书适合以下读者。 ?拥有一定开发经验的Java平台开发人员（Java、Scala、JRuby等）。 ?软件设计师、架构师。 ?系统调优人员。 ?有一定的Java编程基础并希望进一步加深对并行程序的理解的研发人员。 本书的约定和更新 本书在叙述过程中，有如下约定。 ?本书所述的JDK 1.8、JDK 1.9、JDK 1.10分别等同于JDK 8、JDK 9、JDK 10。 ?如无特殊说明，本书的程序、示例均在JDK 1.8以上环境中运行。 相较前一版，本书的主要更新如下。 1. 第3章更新的内容如下。 ?更新了“3.1.3　允许多个线程同时访问：信号量（Semaphore）”。 ?增加了对AbstractQueuedSynchronizer 的介绍。 ?增加了对ConcurrentHashMap在JDK 8中实现的介绍。 2. 第4章更新的内容如下。 ?更新了“4.1.2　减小锁粒度”。 ?增加了对ThreadLocalRandmon实现的介绍。 ?更新了“4.4.2　无锁的线程安全整数：AtomicInteger”中有关原子类实现的介绍。 ?更新了“4.4.3　Java中的指针：Unsafe类”中有关Unsafe类的说明。 3. 第5章更新的内容如下。 ?更新了“5.4.4　CPU Cache的优化：解决伪共享问题”中的示例。 4. 第6章更新内容如下。 ?更新了“6.7.1　更快的原子类：LongAdder”中有关LongAdder的实现。 感谢 本书能够面世，是因为得到了众人的支持。首先，感谢我的妻子，她始终不辞辛劳、毫无怨言地对我照顾有加，这才让我得以腾出大量时间安心工作。其次，感谢所有编辑为我一次又一次地审稿改错，批评指正，帮助本书逐步完善。最后，感谢我的母亲三十年如一日对我的体贴和关心。 参与本书写作的还有薛淑英，特此感谢！ 葛一鸣 读者服务 微信扫码回复：43707 ?获取本书配套源码、参考文献 ?加入“Java架构”读者交流群，与更多同道中人互动 ?获取【百场业界大咖直播合集】（持续更新），仅需1元

目　　录 第1章　走入并行世界 1 1.1　何去何从的并行计算 1 1.1.1　忘掉那该死的并行 2 1.1.2　可怕的现实：摩尔定律的失效 4 1.1.3　柳暗花明：不断地前进 5 1.1.4　光明或是黑暗 6 1.2　你必须知道的几个概念 7 1.2.1　同步（Synchronous）和异步（Asynchronous） 7 1.2.2　并发（Concurrency）和并行（Parallelism） 8 1.2.3　临界区 9 1.2.4　阻塞（Blocking）和非阻塞（Non-Blocking） 9 1.2.5　死锁（Deadlock）、饥饿（Starvation）和活锁（Livelock） 10 1.3　并发级别 11 1.3.1　阻塞 11 1.3.2　无饥饿（Starvation-Free） 11 1.3.3　无障碍（Obstruction-Free） 12 1.3.4　无锁（Lock-Free） 13 1.3.5　无等待（Wait-Free） 13 1.4　有关并行的两个重要定律 14 1.4.1　Amdahl定律 14 1.4.2　Gustafson定律 16 1.4.3　是否相互矛盾 17 1.5　回到Java：JMM 18 1.5.1　原子性（Atomicity） 18 1.5.2　可见性（Visibility） 20 1.5.3　有序性（Ordering） 22 1.5.4　哪些指令不能重排：Happen-Before规则 27 第2章　Java并行程序基础 29 2.1　有关线程你必须知道的事 29 2.2　初始线程：线程的基本操作 32 2.2.1　新建线程 32 2.2.2　终止线程 34 2.2.3　线程中断 38 2.2.4　等待（wait）和通知（notify） 41 2.2.5　挂起（suspend）和继续执行（resume）线程 45 2.2.6　等待线程结束（join）和谦让（yield） 48 2.3　volatile与Java内存模型（JMM） 50 2.4　分门别类的管理：线程组 53 2.5　驻守后台：守护线程（Daemon） 54 2.6　先做重要的事：线程优先级 55 2.7　线程安全的概念与关键字synchronized 57 2.8　程序中的幽灵：隐蔽的错误 61 2.8.1　无提示的错误案例 61 2.8.2　并发下的ArrayList 62 2.8.3　并发下诡异的HashMap 64 2.8.4　初学者常见的问题：错误的加锁 66 第3章　JDK并发包 69 3.1　多线程的团队协作：同步控制 69 3.1.1　超越synchronized的同步工具：重入锁 70 3.1.2　重入锁的好搭档：Condition 79 3.1.3　允许多个线程同时访问：信号量（Semaphore） 83 3.1.4　ReadWriteLock读写锁 85 3.1.5　倒计数器：CountDownLatch 88 3.1.6　循环栅栏：CyclicBarrier 89 3.1.7　线程阻塞工具类：LockSupport 93 3.1.8　深入理解锁：AbstractQueuedSynchronizer 96 3.1.9 Guava和RateLimiter限流 105 3.2　线程复用：线程池 108 3.2.1　什么是线程池 109 3.2.2　不要重复发明轮子：JDK对线程池的支持 110 3.2.3　刨根究底：核心线程池的内部实现 116 3.2.4　超负载了怎么办：拒绝策略 120 3.2.5　自定义线程创建：ThreadFactory 122 3.2.6　我的应用我做主：扩展线程池 123 3.2.7　合理的选择：优化线程池线程数量 126 3.2.8　堆栈去哪里了：在线程池中寻找堆栈 127 3.2.9　分而治之：Fork/Join框架 131 3.2.10　Guava中对线程池的扩展 135 3.3　不要重复发明轮子：JDK的并发容器 137 3.3.1　超好用的工具类：并发集合简介 137 3.3.2　线程安全的HashMap 138 3.3.3　深入浅出ConcurrentHashMap 139 3.3.4　有关List的线程安全 145 3.3.5　高效读写的队列：深度剖析ConcurrentLinkedQueue类 145 3.3.6　高效读取：不变模式下的CopyOnWriteArrayList类 151 3.3.7　数据共享通道：BlockingQueue 152 3.3.8　随机数据结构：跳表（SkipList） 157 3.4　使用JMH进行性能测试 159 3.4.1　什么是JMH 160 3.4.2　Hello JMH 160 3.4.3　JMH的基本概念和配置 163 3.4.4　理解JMH中的Mode 164 3.4.5　理解JMH中的State 166 3.4.6　有关性能的一些思考 166 3.4.7　CopyOnWriteArrayList类与ConcurrentLinkedQueue类 169 第4章　锁的优化及注意事项 172 4.1　有助于提高锁性能的几点建议 173 4.1.1　减少锁持有时间 173 4.1.2　减小锁粒度 174 4.1.3　用读写分离锁来替换独占锁 175 4.1.4　锁分离 175 4.1.5　锁粗化 178 4.2　Java虚拟机对锁优化所做的努力 179 4.2.1　锁偏向 179 4.2.2　轻量级锁 180 4.2.3　自旋锁 180 4.2.4　锁消除 180 4.3　人手一支笔：ThreadLocal 181 4.3.1　ThreadLocal的简单使用 181 4.3.2　ThreadLocal的实现原理 183 4.3.3　对性能有何帮助 189 4.3.4　线程私有的随机数发生器ThreadLocalRandom 192 4.4　无锁 197 4.4.1　与众不同的并发策略：比较交换 197 4.4.2　无锁的线程安全整数：AtomicInteger 198 4.4.3　Java中的指针：Unsafe类 200 4.4.4　无锁的对象引用：AtomicReference 202 4.4.5　带有时间戳的对象引用：AtomicStampedReference 205 4.4.6　数组也能无锁：AtomicIntegerArray 208 4.4.7　让普通变量也享受原子操作：AtomicIntegerFieldUpdater 209 4.4.8　挑战无锁算法：无锁的Vector实现 211 4.4.9　让线程之间互相帮助：细看SynchronousQueue的实现 216 4.5　有关死锁的问题 220 第5章　并行模式与算法 224 5.1　探讨单例模式 224 5.2　不变模式 228 5.3　生产者-消费者模式 230 5.4　高性能的生产者-消费者模式：无锁的实现 235 5.4.1　无锁的缓存框架：Disruptor 235 5.4.2　用Disruptor框架实现生产者-消费者模式的案例 236 5.4.3　提高消费者的响应时间：选择合适的策略 240 5.4.4　CPU Cache的优化：解决伪共享问题 241 5.5　Future模式 244 5.5.1　Future模式的主要参与者 247 5.5.2　Future模式的简单实现 247 5.5.3　JDK中的Future模式 250 5.5.4　Guava对Future模式的支持 252 5.6　并行流水线 254 5.7　并行搜索 258 5.8　并行排序 260 5.8.1　分离数据相关性：奇偶交换排序 260 5.8.2　改进的插入排序：希尔排序 264 5.9　并行算法：矩阵乘法 268 5.10　准备好了再通知我：网络NIO 272 5.10.1　基于Socket的服务端多线程模式 273 5.10.2　使用NIO进行网络编程 278 5.10.3　使用NIO实现客户端 286 5.11　读完了再通知我：AIO 288 5.11.1　AIO EchoServer的实现 288 5.11.2　AIO客户端的实现 291 第6章　Java 8/9/10与并发 294 6.1　Java 8的函数式编程简介 294 6.1.1　函数作为一等公民 295 6.1.2　无副作用 296 6.1.3　声明式的编程方式 296 6.1.4　不变的对象 297 6.1.5　易于并行 297 6.1.6　更少的代码 297 6.2　函数式编程基础 298 6.2.1　FunctionalInterface注释 298 6.2.2　接口默认方法 299 6.2.3　lambda表达式 303 6.2.4　方法引用 304 6.3　一步一步走入函数式编程 306 6.4　并行流与并行排序 311 6.4.1　使用并行流过滤数据 311 6.4.2　从集合得到并行流 312 6.4.3　并行排序 312 6.5　增强的Future：CompletableFuture 313 6.5.1　完成了就通知我 313 6.5.2　异步执行任务 314 6.5.3　流式调用 316 6.5.4　CompletableFuture中的异常处理 316 6.5.5　组合多个CompletableFuture 317 6.5.6　支持timeout的CompletableFuture 319 6.6　读写锁的改进：StampedLock 319 6.6.1　StampedLock的使用示例 320 6.6.2　StampedLock的小陷阱 321 6.6.3　有关StampedLock的实现思想 323 6.7　原子类的增强 326 6.7.1　更快的原子类：LongAdder 327 6.7.2　LongAdder功能的增强版：LongAccumulator 334 6.8　ConcurrentHashMap的增强 335 6.8.1　forEach操作 335 6.8.2　reduce操作 335 6.8.3　条件插入 336 6.8.4　search操作 337 6.8.5　其他新方法 338 6.9　发布订阅模式 338 6.9.1 简单的发布订阅模式案例 340 6.9.2 数据处理链 342 第7章　使用Akka构建高并发程序 344 7.1　新并发模型：Actor 345 7.2　Akka之Hello World 345 7.3　有关消息投递的一些说明 348 7.4　Actor的生命周期 350 7.5　监督策略 354 7.6　选择Actor 359 7.7　消息收件箱（Inbox） 359 7.8　消息路由 361 7.9　Actor的内置状态转换 364 7.10　询问模式：Actor中的Future 367 7.11　多个Actor同时修改数据：Agent 369 7.12　像数据库一样操作内存数据：软件事务内存 372 7.13　一个有趣的例子：并发粒子群的实现 376 7.13.1　什么是粒子群算法 377 7.13.2　粒子群算法的计算过程 377 7.13.3　粒子群算法能做什么 378 7.13.4　使用Akka实现粒子群算法 379 第8章　并行程序调试 388 8.1　准备实验样本 388 8.2　正式起航 389 8.3　挂起整个虚拟机 392 8.4　调试进入ArrayList内部 393 第9章　多线程优化示例——Jetty核心代码分析 397 9.1　Jetty简介与架构 397 9.2　Jetty服务器初始化 399 9.2.1　初始化线程池 399 9.2.2　初始化ScheduledExecutorScheduler 401 9.2.3　初始化ByteBufferPool 402 9.2.4　维护ConnectionFactory 405 9.2.5　计算ServerConnector的线程数量 406 9.3　启动Jetty服务器 406 9.3.1　设置启动状态 406 9.3.2　注册ShutdownMonitor 407 9.3.3　计算系统的线程数量 407 9.3.4　启动QueuedThreadPool 408 9.3.5　启动Connector 408 9.4　处理HTTP请求 411 9.4.1　Accept成功 411 9.4.2　请求处理 413