现代软件规模大、实时性要求高,所以掌握提升处理和响应速度的多线程技术势在必行。本书涵盖多线程编程的核心库、方法、原理,透彻讲解了高并发的本质与应对方法,帮助读者解决高并发环境下的业务瓶颈。
●本书具体内容如下。
第1章讲解Java多线程的基础知识,包括Thread类的核心API的使用。
第2章讲解在多线程中通过synchronized关键字对并发访问进行控制的方法,为读者学习同步知识打好坚实的基础。
第3章介绍线程间通信,以在多线程中进行数据传递。
第4章介绍并发访问时的同步处理实现,包括读写锁(Lock对象)等相关技术点。
第5章剖析定时器Timer类的内部原理。定时器在Android开发中会有深入应用,是很重要的技术点。
第6章介绍单例模式下多线程的全面解决方案。
第7章对前面遗漏的知识点进行补充,使多线程的知识体系更加完整,尽量做到不出现技术空白点。
第8章介绍并发集合框架,可以大大提升开发多线程应用程序的效率。
第9章介绍线程池的使用,让线程管理更规范、高效。这也是Java程序员面试必问的技术点。
1. 畅销书作者撰写,全新升级,新增适用微服务与分布式开发的并发工具与Java线程池
2. 全面剖析多线程编程的核心库、方法、原理,案例式教学,透彻了解高并发本质与应对方法
●为什么写作本书
不管是学习JavaSE、JavaEE、JavaWeb,还是学习Java大数据、Java移动开发、Java分布式、Java微服务,多线程编程都是必不可少的核心技术点。本书是首本多线程技术书,自第1版和第2版出版以来,获得了广大Java程序员与学习者的关注,在技术论坛、博客、公众号等平台涌现了大量针对Java多线程技术的讨论与分享。有些读者在时间根据书中的知识总结了学习笔记,并在博客上进行分享,这种传播知识的精神令人赞赏和尊重,知识就要分享与传播。我也很高兴能为国内IT知识的体系建设尽微薄之力。
然而本书第1版和第2版出版时,基于Java的分布式/微服务技术还没有强调性能的想法,只是单纯地实现RPC远程调用即可,但随着分布式/微服务技术的稳定与推广,我们发现,单机的性能其实仍是分布式/微服务需要关注的基本点,因为只有单机运行环境的性能上去了,分布式/微服务的整体性能才能得到大幅度的提高,而在这中间一定会涉及两个技术点:数据的组织和线程的管理。掌握了这两个技术点,读者就可以自己实现消息队列,实现对数据的入队和出队的管理,这完全可以由现成的Java并发包中的并发集合工具类实现,不需要自己编写代码,从而大大提升了程序员的开发效率,避免了程序员自己重复造轮子的现象。
与此同时,我也收到了很多读者希望扩展或者深入讲解某些知识点的反馈建议,所以决定升级本书。
●第3版与第2版的区别
第3版注重实战知识点的更新,主要是增加了针对数据的组织的第8章(并发集合工具类),以及针对线程的管理的第9章(Java线程池)。
第8章介绍了并发集合框架,这是在多线程环境下使用较多的集合工具类,它一方面可以大大提升开发者开发多线程应用程序的效率,另一方面对数据的组织也更具有规划性,能够满足高并发环境下的使用需求。
第9章增加了线程池的使用,让线程管理更规范、高效。线程池也是Java程序员面试必问的技术点。该章深入方法参数与源代码层面,讲解了有界池和无界池应用,可大大提升读者开发高性能服务器的能力。
第3版还增加了若干实用的技术点。
第1章中丰富了版JDK中的Thread类的API。
第2章中强化了多线程中重要的理论基石栅栏的解释与代码实现。
第3章中增加了以下内容:①?volatile关键字在同步与可视性方面的案例,并着重讲解了该关键字在使用方面的注意事项及技巧;②?使用并发包实现线程间通信的解决方案,以及并发包中同步锁的实现原理;③?线程异步通信机制的解释与版JDK实现代码。
第5章中优化了定时器相关的案例,代码更加简洁、明晰。
第7章中细化了Java线程状态的切换。
本书写作秉承大道至简思想,只介绍Java多线程开发中值得关注的内容,希望能抛砖引玉,以个人的一些想法和见解,为读者拓展出更深入、更全面的思路。
●本书特色
在本书写作的过程中,我尽量减少啰唆的语言,全部以Demo式案例来讲解技术点的实现,使读者看到代码及运行结果后就可以知道该项目要解决的是什么问题,类似于网络中博客的风格,让读者用短的时间学习知识点,明白知识点如何应用,以及在使用时要避免什么,从而快速学习并解决问题。
●读者对象
Java程序员
系统架构师
Java多线程开发者
Java并发开发者
大数据开发者
其他对多线程技术感兴趣的人员
●如何阅读本书
本书本着实用、易懂的原则,用9章来介绍Java多线程相关的技术。
第1章讲解了Java多线程的基础,包括Thread类的核心API的使用。
第2章讲解了在多线程中对并发访问的控制,主要是synchronized关键字的使用。因为此关键字在使用上非常灵活,所以该章给出很多案例来说明此关键字的用法,为读者学习同步知识点打好坚实的基础。
第3章讲解了线程之间的通信与交互细节。该章主要介绍wait()、notifyAll()和notify()方法的使用,使线程间能互相通信,合作完成任务,还介绍了ThreadLocal类的使用,学习完该章,读者就能在Thread多线程中进行数据的传递了。
第4章讲解了锁的使用。因为synchronized关键字使用起来比较麻烦,所以Java 5及以上版本中提供了锁(Lock对象),更好地实现了并发访问时的同步处理,包括读写锁等。
第5章讲解了Timer定时器类,其内部原理就是使用多线程技术。定时器是执行计划任务时很重要的技术点,在进行Android开发时也会有深入的使用。
第6章讲解的单例模式虽然很简单,但如果遇到多线程将会变得非常麻烦。如何在多线程中解决这么棘手的问题呢?该章会全面给出解决方案。
第7章对前面章节遗漏的技术空白点进行补充,使多线程的知识体系更加完整。
第8章讲解了并发集合框架的使用,几乎涵盖所有主流的并发集合工具类,并细化到API级,包含阻塞和非阻塞的使用等。
第9章讲解了线程池的使用,包括读者应该着重掌握的ThreadPool线程池构造方法参数的特性以及其他常用API的使用,并详细讲解了线程池内部源代码的实现。
高洪岩
某世界500强公司项目经理,有10年Java开发和项目管理经验,精通Java语言,擅长Java EE、分布式、微服务、高性能服务器架构、智能报表、多线程和高并发相关的技术内容,理论与实践经验颇丰,也积极参与开源项目的开发与设计,涉及Dubbo、Jedis、Pulsar、ZooKeeper等主流开源项目。
著有《Java多线程编程核心技术》《Java并发编程:核心方法与框架》《NIO与Socket编程技术指南》《Java EE核心框架实战(第2版)》等多本图书。
第1章 Java多线程技能 1
1.1 进程和线程的定义及多线程的优点 1
1.2 使用多线程 5
1.2.1 继承Thread类 6
1.2.2 使用常见的3个命令分析线程的信息 8
1.2.3 线程随机性的展现 10
1.2.4 执行start()的顺序不代表执行run()的顺序 12
1.2.5 实现Runnable接口 14
1.2.6 使用Runnable接口实现多线程的优点 15
1.2.7 public Thread(Runnable target)中的target参数 16
1.2.8 实例变量共享导致的非线程安全问题与相应的解决方案 18
1.2.9 Servlet技术也会引起非线程安全问题 22
1.2.10 留意i--与System.out.println()出现的非线程安全问题 25
1.2.11 方法run()被JVM所调用 27
1.3 方法currentThread() 27
1.4 方法isAlive() 30
1.5 方法sleep(long millis) 33
1.6 方法sleep(long millis, int nanos) 34
1.7 方法StackTraceElement[] getStack-Trace() 35
1.8 方法static void dumpStack() 36
1.9 方法Map getAllStackTraces() 37
1.10 方法getId() 39
1.11 停止线程 40
1.11.1 停止不了的线程 41
1.11.2 判断线程是不是停止状态 42
1.11.3 清除中断状态的使用场景 44
1.11.4 能停止的线程异常法 48
1.11.5 在sleep状态下停止 51
1.11.6 使用stop()暴力停止线程 53
1.11.7 方法stop()与java.lang.Thread-Death异常 55
1.11.8 使用stop()释放锁导致数据结果不一致 57
1.11.9 使用return;语句停止线程的缺点及相应的解决方案 59
1.12 暂停线程 61
1.12.1 方法suspend()与resume()的使用 62
1.12.2 方法suspend()与resume()的缺点独占 63
1.12.3 方法suspend()与resume()的缺点数据不完整 66
1.12.4 使用LockSupport类实现线程暂停与恢复 67
1.13 方法yield() 69
1.14 线程的优先级 70
1.14.1 线程优先级的继承特性 71
1.14.2 线程优先级的规律性 72
1.14.3 线程优先级的随机性 75
1.14.4 看谁跑得快 76
1.15 守护线程 78
1.16 并发与并行 79
1.17 同步与异步 80
1.18 多核CPU不一定比单核CPU运行快 81
1.19 本章小结 82
第2章 对象及变量的并发访问 83
2.1 synchronized同步方法 83
2.1.1 方法内的变量是线程安全的 83
2.1.2 实例变量非线程安全问题及解决方案 85
2.1.3 同步synchronized在字节码指令中的原理 88
2.1.4 多个对象多个锁 90
2.1.5 synchronized方法将对象作为锁 92
2.1.6 脏读与解决 97
2.1.7 synchronized锁重入 99
2.1.8 继承环境下的锁重入 100
2.1.9 出现异常,锁自动释放 102
2.1.10 非同步方法?:不使用synchronized重写方法 104
2.2 synchronized同步语句块 106
2.2.1 synchronized方法的弊端 106
2.2.2 synchronized同步代码块的使用 109
2.2.3 用同步代码块解决同步方法的弊端 111
2.2.4 一半异步,一半同步 112
2.2.5 synchronized代码块间的同步性 114
2.2.6 方法println()也是同步的 116
2.2.7 验证synchronized(this)同步代码块是锁定当前对象的 117
2.2.8 将任意对象作为锁 119
2.2.9 多个锁就是异步执行 121
2.2.10 验证方法被调用是随机的 124
2.2.11 不同步导致的逻辑错误与解决方案 125
2.2.12 细化验证3个结论 129
2.2.13 类对象的单例性 134
2.2.14 静态同步?:synchronized方法与synchronized(class)代码块 135
2.2.15 同步synchronized方法可以对类的所有对象实例起作用 139
2.2.16 同步synchronized(class)代码块可以对类的所有对象实例起作用 141
2.2.17 String常量池特性与同步问题 143
2.2.18 synchronized方法无限等待问题与解决方案 146
2.2.19 多线程的死锁 148
2.2.20 内置类与静态内置类 150
2.2.21 内置类与同步?:实验1 153
2.2.22 内置类与同步?:实验2 155
2.2.23 锁对象改变导致异步执行 156
2.2.24 锁对象不改变依然是同步执行 159
2.2.25 同步写法案例比较 161
2.2.26 方法holdsLock(Object obj)的使用 161
2.2.27 临界区 162
2.3 volatile关键字 162
2.3.1 可见性的测试 163
2.3.2 原子性与非原子性的测试 171
2.3.3 禁止代码重排序的测试 179
2.4 本章小结 190
第3章 线程间通信 191
3.1 wait/ notify机制 191
3.1.1 不使用wait/notify机制进行通信的缺点 191
3.1.2 什么是wait/notify机制 194
3.1.3 wait/notify机制的原理 194
3.1.4 方法wait()的基本用法 195
3.1.5 使用代码完整实现wait /notify机制 196
3.1.6 使用wait/notify机制实现线程销毁 198
3.1.7 对业务代码进行封装 200
3.1.8 线程状态的切换 203
3.1.9 方法wait()导致锁立即释放 204
3.1.10 方法sleep()不释放锁 206
3.1.11 方法notify()不立即释放锁 206
3.1.12 方法interrupt()遇到方法wait() 208
3.1.13 方法notify()只通知一个线程 210
3.1.14 方法notifyAll()通知所有线程 212
3.1.15 方法wait(long)的基本用法 213
3.1.16 方法wait(long)自动向下运行的条件 215
3.1.17 通知过早与相应的解决方案 218
3.1.18 等待条件发生变化 220
3.1.19 生产者/消费者模式实现 224
3.1.20 在管道中传递字节流 239
3.1.21 在管道中传递字符流 241
3.1.22 利用wait/notify机制实现交叉备份 244
3.1.23 方法sleep()和wait()的区别 247
3.2 方法join()的使用 247
3.2.1 学习方法join()前的铺垫 247
3.2.2 用方法join()解决问题 248
3.2.3 方法join()和interrupt()出现异常 250
3.2.4 方法join(long)的使用 252
3.2.5 方法join(long)与sleep(long)的区别 254
3.2.6 方法join()后的代码提前运行 257
3.2.7 方法join(long millis, int nanos)的使用 261
3.3 类ThreadLocal的使用 262
3.3.1 方法get()与null 262
3.3.2 类ThreadLocal存取数据流程分析 263
3.3.3 验证线程变量的隔离性 266
3.3.4 解决get()返回null的问题 270
3.3.5 验证重写initialValue()方法的隔离性 271
3.3.6 使用remove()方法的必要性 272
3.4 类InheritableThreadLocal的使用 276
3.4.1 类ThreadLocal不能实现值继承 277
3.4.2 使用InheritableThreadLocal体现值继承特性 278
3.4.3 值继承特性在源代码中的执行流程 280
3.4.4 父线程有的值,子线程还是旧值?:不可变类型 285
3.4.5 子线程有的值,父线程还是旧值?:不可变类型 286
3.4.6 子线程可以感应对象属性值的变化?:可变类型 288
3.4.7 重写childValue方法实现对继承值的加工 291
3.5 本章小结 291
第4章 锁的使用 292
4.1 使用ReentrantLock类 292
4.1.1 使用ReentrantLock实现同步 292
4.1.2 验证多代码块间的同步性 294
4.1.3 方法await()的错误用法与相应的解决方案 297
4.1.4 使用方法await()和方法signal()实现wait/notify 300
4.1.5 方法await()暂停的原理 302
4.1.6 通知部分线程?:错误用法 306
4.1.7 通知部分线程?:正确用法 308
4.1.8 实现生产者/消费者模式一对一交替打印 311
4.1.9 实现生产者/消费者模式多对多交替打印 313
4.1.10 公平锁与非公平锁 315
4.1.11 方法getHoldCount()的使用 318
4.1.12 方法getQueueLength()的使用 319
4.1.13 方法getWaitQueueLength(Condition condition)的使用 321
4.1.14 方法hasQueuedThread(Thread thread)的使用 322
4.1.15 方法hasQueuedThreads()的使用 323
4.1.16 方法hasWaiters(Condition condition)的使用 324
4.1.17 方法isFair()的使用 326
4.1.18 方法isHeldByCurrentThread()的使用 326
4.1.19 方法isLocked()的使用 327
4.1.20 方法lockInterruptibly()的使用 328
4.1.21 方法tryLock()的使用 330
4.1.22 方法tryLock(long timeout, Time-Unit unit)的使用 331
4.1.23 方法await(long time, TimeUnit unit)的使用 333
4.1.24 方法awaitNanos(long nanos-Timeout)的使用 334
4.1.25 方法awaitUntil(Date deadline)的使用 335
4.1.26 方法awaitUninterruptibly()的使用 337
4.1.27 实现线程按顺序执行业务 339
4.2 使用ReentrantReadWriteLock类 342
4.2.1 类ReentrantLock的缺点 342
4.2.2 读读共享 344
4.2.3 写写互斥 344
4.2.4 读写互斥 345
4.2.5 写读互斥 346
4.3 本章小结 347
第5章 定时器 348
5.1 定时器的使用 348
5.1.1 方法schedule(TimerTask task, Date time)的测试 349
5.1.2 方法schedule(TimerTask task, Date f?irstTime, long period)的测试 357
5.1.3 方法schedule(TimerTask task, long delay)的测试 365
5.1.4 方法schedule(TimerTask task, long delay, long period)的测试 365
5.1.5 方法scheduleAtFixedRate(TimerTask task, Date f?irst-Time, long period)的测试 366
5.2 本章小结 374
第6章 单例模式与多线程 375
6.1 单例模式与多线程 375
6.1.1 立即加载/饿汉模式 375
6.1.2 延迟加载/懒汉模式 377
6.1.3 使用静态内置类实现单例模式 388
6.1.4 序列化与反序列化的单例模式实现 389
6.1.5 使用static代码块实现单例模式 392
6.1.6 使用enum枚举数据类型实现单例模式 393
6.1.7 完善使用enum枚举实现单例模式 394
6.2 本章小结 396
第7章 拾遗增补 397
7.1 线程的状态 397
7.1.1 验证NEW、RUNNABLE和TERMINATED 399
7.1.2 验证TIMED_WAITING 400
7.1.3 验证BLOCKED 401
7.1.4 验证WAITING 403
7.2 线程组 404
7.2.1 线程对象关联线程组?:一级关联 404
7.2.2 线程对象关联线程组?:多级关联 406
7.2.3 线程组自动归属特性 407
7.2.4 获取根线程组 408
7.2.5 线程组内加线程组 409
7.2.6 组内的线程批量停止 409
7.2.7 递归取得与非递归取得组内对象 410
7.3 Thread.activeCount()方法的使用 412
7.4 Thread.enumerate(Thread tarray[])方法的使用 412
7.5 再次验证线程执行有序性 412
7.6 类SimpleDateFormat非线程安全 414
7.6.1 出现异常 415
7.6.2 解决方法1 417
7.6.3 解决方法2 418
7.7 线程中出现异常的处理 420
7.7.1 线程出现异常的默认行为 420
7.7.2 使用setUncaughtException-Handler()方法进行异常处理 421
7.7.3 使用setDefaultUncaught-ExceptionHandler()方法进行异常处理 422
7.8 线程组内处理异常 423
7.9 线程异常处理的优先性 426
7.10 本章小结 431
第8章 并发集合框架 432
8.1 集合框架结构 432
8.1.1 接口Iterable 432
8.1.2 接口Collection 432
8.1.3 接口List 433
8.1.4 接口Set 434
8.1.5 接口Queue 435
8.1.6 接口Deque 435
8.2 非阻塞队列 435
8.2.1 类ConcurrentHashMap的使用 436
8.2.2 类ConcurrentSkipListMap的使用 442
8.2.3 类ConcurrentSkipListSet的使用 444
8.2.4 类ConcurrentLinkedQueue的使用 447
8.2.5 类ConcurrentLinkedDeque的使用 451
8.2.6 类CopyOnWriteArrayList的使用 453
8.2.7 类CopyOnWriteArraySet的使用 454
8.3 阻塞队列 456
8.3.1 类ArrayBlockingQueue与公平/非公平锁的使用 456
8.3.2 类PriorityBlockingQueue的使用 461
8.3.3 类LinkedBlockingQueue的使用 463
8.3.4 类LinkedBlockingDeque的使用 463
8.3.5 类SynchronousQueue的使用 463
8.3.6 类DelayQueue的使用 466
8.3.7 类LinkedTransferQueue的使用 467
8.4 本章小结 476
第9章 线程池类ThreadPoolExecutor的使用 477
9.1 Executor接口介绍 477
9.2 使用Executors工厂类创建线程池 481
9.2.1 使用newCachedThreadPool()方法创建无界线程池 481
9.2.2 验证newCachedThreadPool()方法创建线程池和线程复用特性 483
9.2.3 使用newCachedThreadPool (ThreadFactory)方法定制线程工厂 486
9.2.4 使用newCachedThread-Pool()方法创建无界线程池的缺点 487
9.2.5 使用newFixedThreadPool(int)
方法创建有界线程池 488
9.2.6 使用newSingleThread-Executor()方法创建单一线程池 490
9.3 ThreadPoolExecutor类的使用 491
9.3.1 队列LinkedBlocking-Queue、ArrayBlocking-Queue和Synchronous-Queue的基本使用 491
9.3.2 构造方法参数详解 495
9.3.3 方法shutdown()和shutdownNow() 521
9.3.4 方法List shutdown-Now()返回值的作用 525
9.3.5 方法shutdown()和shutdown-Now()与中断 527
9.3.6 方法isShutdown() 529
9.3.7 方法isTerminating()和isTerminated() 530
9.3.8 方法awaitTermination(long timeout,TimeUnit unit) 531
9.3.9 工厂ThreadFactory Thread UncaughtExceptionHandler处理异常 533
9.3.10 方法set/getRejected-ExecutionHandler() 537
9.3.11 方法allowsCoreThreadTime-Out和allowCoreThreadTime-Out(bool) 539
9.3.12 方法prestartCoreThread()和prestartAllCoreThreads() 541
9.3.13 方法getCompletedTask-Count() 542
9.3.14 线程池ThreadPoolExecutor的拒绝策略 543
9.3.15 方法afterExecute()和beforeExecute() 549
9.3.16 方法remove(Runnable)的使用 551
9.3.17 多个get方法的测试 555
9.4 本章小结 558