Java并发编程

一般 run()方法执行完，线程就会正常结束，然而，常常有些线程是伺服线程。它们需要长时间的 运行，只有在外部某些条件满足的情况下，才能关闭这些线程。使用一个变量来控制循环，例如： 最直接的方法就是设一个boolean 类型的标志，并通过设置这个标志为 true或 false 来控制 while 循环是否退出。 定义了一个退出标志 exit，当 exit 为 true 时，while 循环退出，exit 的默认值为 false.在定义 exit 时，使用了一个 Java 关键字 volatile，这个关键字的目的是使 exit 同步，也就是说在同一时刻只 能由一个线程来修改 exit 的值。

线程处于阻塞状态：如使用了 sleep,同步锁的 wait,socket 中的 receiver,accept 等方法时， 会使线程处于阻塞状态。当调用线程的 interrupt()方法时，会抛出 InterruptException 异常。 阻塞中的那个方法抛出这个异常，通过代码捕获该异常，然后 break 跳出循环状态，从而让 我们有机会结束这个线程的执行。通常很多人认为只要调用 interrupt 方法线程就会结束，实 际上是错的， 一定要先捕获 InterruptedException 异常之后通过 break 来跳出循环，才能正 常结束 run 方法。

线程未处于阻塞状态：使用 isInterrupted()判断线程的中断标志来退出循环。当使用 interrupt()方法时，中断标志就会置 true，和使用自定义的标志来控制循环是一样的道理。

程序中可以直接使用 thread.stop()来强行终止线程，但是 stop 方法是很危险的，就象突然关
闭计算机电源，而不是按正常程序关机一样，可能会产生不可预料的结果，不安全主要是：
thread.stop()调用之后，创建子线程的线程就会抛出 ThreadDeatherror 的错误，并且会释放子
线程所持有的所有锁。一般任何进行加锁的代码块，都是为了保护数据的一致性，如果在调用
thread.stop()后导致了该线程所持有的所有锁的突然释放(不可控制)，那么被保护数据就有可能呈
现不一致性，其他线程在使用这些被破坏的数据时，有可能导致一些很奇怪的应用程序错误。因
此，并不推荐使用 stop 方法来终止线程。

corePoolSize

maximumPoolSize

keepAliveTime

unit

workQueue

threadFactory

handler

Executor.execute()

ExecutorService.submit()

用于获取异步任务的执行结果，并非线程池管理类，但与线程池配合使用

执行任务的取消

查询任务是否已经执行完成

获取任务的执行结果

实现RunnableFuture接口，即可以作为Runnable被执行，也可以 作为Future得到Callable的返回值

内部基于AQS实现

key-value键值对

红黑树节点

就相当于一颗红黑树，其构造方法其实就是构造红黑树的过程

辅助节点，用于ConcurrentHashMap扩容操作

sizeCtl

ConcurrentHashMap初始化方法

只能有一个线程参与初始化过程，其他线程必须挂起

构造函数不做初始化过程，初始化真正是在put操作触发

步骤

根据hash值计算节点插入在table的位置，如果该位置为空，则直接插入，否则插入到链表或者树中

真实情况较为复杂

table为null，线程进入初始化步骤，如果有其他线程正在初始化，该线程挂起

如果插入的当前 i 位置 为null，说明该位置是第一次插入，利用CAS插入节点即可，插入成功，则调用addCount判断是否需要扩容。 若插入失败，则继续匹配（自旋）

若该节点的hash ==MOVED（-1），表示有线程正在进行扩容，则进入扩容进程中

其余情况就是按照链表或者红黑树结构插入节点，但是这个过程需要加锁（synchronized）

table ==null ；return null

从链表/红黑树节点获取

多线程扩容

步骤

红黑树是一种自平衡二叉查找树，是计算机科学领域中的一种数据结构，典型的用途是实现关联数组，存储有序的数据。 别称"对称二叉B树"，它是复杂的，但它的操作有着良好的最坏情况运行时间，并且在实践中是高效的。 它可以在O(logn)时间内做查找，插入和删除，这里的n是树的结点个数

特性

基于ReentrantLock实现分段锁来实现的segment。jdk1.7中采用Segment + HashEntry的方式进行实现

1.8中放弃了Segment臃肿的设计，取而代之的是采用Node + CAS + Synchronized来保证并发安全进行实现

由很多层结构组成，level是通过一定的概率随机产生的

每一层都是一个有序的链表，默认是升序，也可以根据创建映射时所提供的Comparator进行排序，具体取决于使用的构造方法

最底层(Level 1)的链表包含所有元素

如果一个元素出现在Level i 的链表中，则它在Level i 之下的链表也都会出

每个节点包含两个指针，一个指向同一链表中的下一个元素，一个指向下面一层的元素

最大堆，父节点的键值总是大于或等于任何一个子节点的键值

最小堆，父节点的键值总是小于或等于任何一个节点的键值

在单线程环境下不能改变程序运行的结果

存在数据依赖关系的不允许重排序

如果两个操作访问统一变量，且这两个操作有一个是写操作，此时这两个操作之间就存在数据依赖性，

写一个变量之后，再读一个变量

写一个变量之后，再写一个变量

读一个变量后，再写一个变量

一个线程中的所有操作必须按照程序的顺序来执行

所有线程都只能看到一个单一的操作执行顺序，不管程序是否同步

每个操作都必须原子执行且立刻对所有线程可见

如果一个操作happens-before另一个操作，那么第一个操作的执行结果将对第二个操作可见，而且第一个操作的执行顺序排在第二个操作之前。 两个操作之间存在happens-before关系，并不意味java平台的具体实现必须按照happens-before关系指定的顺序来执行。如果重排序后的执行结构，与按 happens-before关系来执行的结果一致，那么这种重排序并不非法(JMM允许这种重排序） as-if-serial语义保证单线程内程序的执行结果不被改变，happens-before关系保证正确同步的多线程程序的执行结构不被改变

synchronized的锁就是保存在Java对象头中的

包括两部分数据

monitorenter

monitorexit

初始时为NULL表示当前没有任何线程拥有该monitor record，当线程成功拥有该锁后保存线程唯一标识，当锁被释放时又设置为NULL

标记方式

自旋方式

适应性自旋

阻塞方式

若不存在数据竞争的情况，JVM会消除锁机制

判断依据:变量逃逸

将多个连续的加锁、解锁操作连接在一起，扩展成一个范围更大的锁。例如for循环内部获取锁

当写一个Volatile 变量的时候，JMM会把该线程对应的本地内存的共享变量刷新到主内存中. 使用上面的代码中示例， 当在执行writer() 方法 写了flag变量后，JMM会立即可本地内存的共享变量刷新到主内存中

当读取一个volatile变量的时候，JMM会将当前线程的本地内存共享变量设置为无效，线程在接下来的操作，会从主内存中读取共享变量。

获取锁

释放锁

获取锁

释放锁

是用来创建和其他同步类的基本线程阻塞原语

每个使用LockSupport的线程都会与一个许可关联，如果该许可可用，并且可在进行中使用，则调用park()将立即返回，否则可能阻塞。 如果许可尚不可用，则可以调用unpark使其可用

park()和unpark()

旋CAS如果长时间不成功，会给CPU带来非常大的执行开销

当对一个共享变量执行操作时，我们可以使用循环CAS的方式来保证原子操作，但是对多个共享变量操作时，循环CAS就无法保证操作的原子 性，这个时候就可以用锁。还有一个取巧的办法，就是把多个共享变量合并成一个共享变量来操作。比如，有两个共享变量i＝2，j=a，合并一下ij=2a，然后 用CAS来操作ij。从Java 1.5开始，JDK提供了AtomicReference类来保证引用对之间的原子性，就可以把多个变量放在一个对象里来进行CAS操作。

因为CAS需要在操作值的时候，检查值有没有发生变化，如果没有发生变化则更新，但是如果一个值 原来是A，变成了B，又变成了B，那么使用CAS进行检查 时会发现它的值没有发生变化，但是实际上却变化了。

解决方法

返回此线程局部变量的当前线程副本中的值

返回此线程局部变量的当前线程的值

移除此线程局部变量当前线程的值

将此线程局部变量的当前线程副本中的值设置为指定值

key弱引用，value强引用，无法回收

执行任务的线程池

表示任务，用于ForkJoinPool的任务抽象

执行任务的工作现场