商品参数
| 实战Java高并发程序设计 |
| |
定价 |
69.00 |
| 出版社 |
电子工业出版社 |
| 版次 |
1 |
| 出版时间 |
2015年11月 |
| 开本 |
16开 |
| 作者 |
葛一鸣 |
| 装帧 |
平装 |
| 页数 |
0 |
| 字数 |
0 |
| ISBN编码 |
9787121273049 |
内容介绍
精彩导读
4.4.6 数组也能无锁：AtomicIntegerArray
除了提供基本数据类型外，JDK还为我们准备了数组等复合结构。D前可用的原子数组有：AtomicIntegerArray、AtomicLongArray和AtomicReferenceArray，分别表示整数数组、long型数组和普通的对象数组。
这里以AtomicIntegerArray为例，展示原子数组的使用方式。
AtomicIntegerArray本质上是对int[]类型的封装，使用Unsafe类通过CAS的方式控制int[]在多线程下的安全性。它提供了以下几个核心API：
//获得数组Di个下标的元素
public final int get(int i)
//获得数组的长度
public final int length()
//将数组Di个下标设置为newValue，并返回旧的值
public final int getAndSet(int i, int newValue)
//进行CAS操作，如果Di个下标的元素等于expect，则设置为update，设置成功返回true
public final boolean compareAndSet(int i, int expect, int update)
//将Di个下标的元素加1
public final int getAndIncrement(int i)
//将Di个下标的元素减1
public final int getAndDecrement(int i)
//将Di个下标的元素增加delta（delta可以是负数）
public final int getAndAdd(int i, int delta)
下面给出一个简单的示例，展示AtomicIntegerArray的使用：
01 public class AtomicIntegerArrayDemo {
02 static AtomicIntegerArray arr = new AtomicIntegerArray(10);
03 public static class AddThread implements Runnable{
04 public void run(){
05 for(int k=0;k<10000;k )
06 arr.getAndIncrement(k%arr.length());
07 }
08 }
09 public static void main(String[] args) throws InterruptedException {
10 Thread[] ts=new Thread[10];
11 for(int k=0;k<10;k ){
12 ts[k]=new Thread(new AddThread());
13 }
14 for(int k=0;k<10;k ){ts[k].start();}
15 for(int k=0;k<10;k ){ts[k].join();}
16 System.out.println(arr);
17 }
18 }
上述代码D2行，申明了一个内含10个元素的数组。D3行定义的线程对数组内10个元素进行累加操作，每个元素各加1000次。D11行，开启10个这样的线程。因此，可以预测，如果线程安全，数组内10个元素的值必然都是10000。反之，如果线程不安全，则部分或者全部数值会小于10000。
程序的输出结果如下：
[10000, 10000, 10000, 10000, 10000, 10000, 10000, 10000, 10000, 10000]
这说明AtomicIntegerArray确实合理地保证了数组的线程安全性。
作者介绍
作者简介
葛一鸣：51CTO特约讲师，国家认证系统分析师，获得Oracle OCP认证。长期从事Java软件开发工作，对Java程序设计、JVM有深入的研究，对设计模式、人工智能、神经网络、数据挖掘等技术有浓厚兴趣，著有《自己动手写神经网路》电子书和《实战Java虚拟机》一书。
郭超：J职于杭州市道路运输管理局信息中心,主要从事大型交通管理系统的分布式管理和并发模型设计，对Java的研究比较深入，专注于分布式应用和并发应用。
目录
目录
D1章 走入并行SJ
1.1 何去何从的并行计算
1.1.1 忘掉那该死的并行
1.1.2 可怕的现实：摩尔定律的失效
1.1.3 柳暗花明：不断地前进
1.1.4 光明或是黑暗
1.2 你必须知道的几个概念
1.2.1 同步（SynchroDus）和异步（AsynchroDus）
1.2.2 并发（Concurrency）和并行（Parallelism）
1.2.3 临界区
1.2.4 阻塞（Blocking）和非阻塞（Non-Blocking）
1.2.5 死锁（Deadlock）、饥饿（Starvation）和活锁（Livelock）
1.3 并发级别
1.3.1 阻塞（Blocking）
1.3.2 无饥饿（Starvation-Free）
1.3.3 无障碍（Obstruction-Free）
1.3.4 无锁（Lock-Free）
1.3.5 无等待（Wait-Free）
1.4 有关并行的两个重要定律
1.4.1 Amdahl定律
1.4.2 Gustafson定律
1.4.3 Amdahl定律和Gustafson定律是否相互矛盾
1.5 回到Java：JMM
1.5.1 原子性（Atomicity）
1.5.2 可见性（Visibility）
1.5.3 有序性（Ordering）
1.5.4 哪些指令不能重排：Happen-Before规则
1.6 参考文献
D2章 Java并行程序基础
2.1 有关线程你必须知道的事
2.2 初始线程：线程的基本操作
2.2.1 新建线程
2.2.2 终止线程
2.2.3 线程中断
2.2.4 等待（wait）和通知（Dtify）
2.2.5 挂起（suspend）和继续执行（resume）线程
2.2.6 等待线程结束（join）和谦让（yield）
2.3 volatile与Java内存模型（JMM）
2.4 分门别类的管理：线程组
2.5 驻守后台：守护线程（Daemon）
2.6 先干重要的事：线程优先级
2.7 线程安全的概念与synchronized
2.8 程序中的幽灵：隐蔽的错误
2.8.1 无提示的错误案例
2.8.2 并发下的ArrayList
2.8.3 并发下诡异的HashMap
2.8.4 初学者常见问题：错误的加锁
2.9 参考文献
D3章 JDK并发包
3.1 多线程的团队协作：同步控制
3.1.1 synchronized的功能扩展：重入锁
3.1.2 重入锁的好搭档：Condition条件
3.1.3 允许多个线程同时访问：信号量（Semaphore）
3.1.4 ReadWriteLock读写锁
3.1.5 DJS器：CountDownLatch
3.1.6 循环栅栏：CyclicBarrier
3.1.7 线程阻塞工具类：LockSupport
3.2 线程复用：线程池
3.2.1 什么是线程池
3.2.2 不要重复发明轮子：JDK对线程池的支持
3.2.3 刨根究底：核心线程池的内部实现
3.2.4 超负载了怎么办：拒绝策略
3.2.5 自定义线程创建：ThreadFactory
3.2.6 我的应用我做主：扩展线程池
3.2.7 合理的选择：优化线程池线程数量
3.2.8 堆栈去哪里了：在线程池中寻找堆栈
3.2.9 分而治之：Fork/Join框架
3.3 不要重复发明轮子：JDK的并发容器
3.3.1 超好用的工具类：并发集合简介
3.3.2 线程安全的HashMap
3.3.3 有关List的线程安全
3.3.4 高效读写的队列：深度剖析ConcurrentLinkedQueue
3.3.5 高效读取：不变模式下的CopyOnWriteArrayList
3.3.6 数据共享通道：BlockingQueue
3.3.7 随机数据结构：跳表（SkipList）
3.4 参考资料
D4章 锁的优化及注意事项
4.1 有助于提高"锁"性能的几点建议
4.1.1 减小锁持有时间
4.1.2 减小锁粒度
4.1.3 读写分离锁来替换D占锁
4.1.4 锁分离
4.1.5 锁粗化
4.2 Java虚拟机对锁优化所做的努力
4.2.1 锁偏向
4.2.2 轻量级锁
4.2.3 自旋锁
4.2.4 锁消除
4.3 人手一支笔：ThreadLocal
4.3.1 ThreadLocal的简单使用
4.3.2 ThreadLocal的实现原理
4.3.3 对性能有何帮助
4.4 无锁
4.4.1 与众不同的并发策略：比较交换（CAS）
4.4.2 无锁的线程安全整数：AtomicInteger
4.4.3 Java中的指针：Unsafe类
4.4.4 无锁的对象引用：AtomicReference
4.4.5 带有时间戳的对象引用：AtomicStampedReference
4.4.6 数组也能无锁：AtomicIntegerArray
4.4.7 让普通变量也享受原子操作：AtomicIntegerFieldUpdater
4.4.8 挑战无锁算法：无锁的Vector实现
4.4.9 让线程之间互相帮助：细看SynchroDusQueue的实现
4.5 有关死锁的问题
4.6 参考文献
D5章 并行模式与算法
5.1 探讨单例模式
5.2 不变模式
5.3 生产者-消费者模式
5.4 高性能的生产者-消费者：无锁的实现
5.4.1 无锁的缓存框架：Disruptor
5.4.2 用Disruptor实现生产者-消费者案例
5.4.3 提高消费者的响应时间：选择合适的策略
5.4.4 CPU Cache的优化：解决伪共享问题
5.5 Future模式
5.5.1 Future模式的主要角色
5.5.2 Future模式的简单实现
5.5.3 JDK中的Future模式
5.6 并行流水线
5.7 并行搜索
5.8 并行排序
5.8.1 分离数据相关性：奇偶交换排序
5.8.2 改进的插入排序：希尔排序
5.9 并行算法：矩阵乘法
5.10 准备好了再通知我：网络NIO
5.10.1 基于Socket的服务端的多线程模式
5.10.2 使用NIO进行网络编程
5.10.3 使用NIO来实现客户端
5.11 读完了再通知我：AIO
5.11.1 AIO EchoServer的实现
5.11.2 AIO Echo客户端实现
5.12 参考文献
D6章 Java 8与并发
6.1 Java 8的函数式编程简介
6.1.1 函数作为一等公民
6.1.2 无副作用
6.1.3 申明式的（Declarative）
6.1.4 不变的对象
6.1.5 易于并行
6.1.6 更少的代码
6.2 函数式编程基础
6.2.1 FunctionalInterface注释
6.2.2 接口默认方法
6.2.3 lambda表达式
6.2.4 方法引用
6.3 一步一步走入函数式编程
6.4 并行流与并行排序
6.4.1 使用并行流过滤数据
6.4.2 从集合得到并行流
6.4.3 并行排序
6.5 增强的Future：CompletableFuture
6.5.1 完成了J通知我
6.5.2 异步执行任务
6.5.3 流式调用
6.5.4 CompletableFuture中的异常处理
6.5.5 组合多个CompletableFuture
6.6 读写锁的改进：StampedLock
6.6.1 StampedLock使用示例
6.6.2 StampedLock的小陷阱
6.6.3 有关StampedLock的实现思想
6.7 原子类的增强
6.7.1 更快的原子类：LongAdder
6.7.2 LongAdder的功能增强版：LongAccumulator
6.8 参考文献
D7章 使用Akka构建高并发程序
7.1 新并发模型：Actor
7.2 Akka之Hello World
7.3 有关消息投递的一些说明
7.4 Actor的生命周期
7.5 监督策略
7.6 选择Actor
7.7 消息收件箱（Inbox）
7.8 消息路由
7.9 Actor的内置状态转换
7.10 询问模式：Actor中的Future
7.11 多个Actor同时修改数据：Agent
7.12 像数据库一样操作内存数据：软件事务内存
……
