引:面向对象的编程思想极大的提升了现在软件开发的生产效率和软件可以达到的规模,但是现实中对象在一项工作进行期间,会被不停地中断和切换,对象的属性可能会在中断期间被修改和变“脏”,所以我们在谈“高效并发”之前必须先保证并发的正确性和如何实现线程安全。
线程的安全
在《Java Concurrency In Practice》一书中这样定义线程安全:当多个线程访问一个对象时,如果不用考虑这些线程在运行时环境下得调度和交替执行,也不需要进行额外的同步,或者在调用方进行任何其他的协调操作,调用这个对象的行为都可以获得正确地结果,那这个对象是线程安全的。
它要求线程安全的代码都必须具备一个特征:代码本身封装了所有必要的正确性保障手段(如互斥同步等),令调用者无需关心多线程的问题,更无需自己采用任何措施来保障多线程的正确调用。
Java语言中的线程安全
在讨论线程安全的时候,都会限定于多个线程之间存在共享数据访问这个前提,我们按照线程安全的“安全程度”由强至弱来排序,可以将Java语言中各种操作共享的数据分为以下5类:不可变、绝对线程安全、相对线程安全、线程兼容和线程对立。
不可变
在Java语言中,不可变对象一定是线程安全的,无论是对象的方法实现还是方法调用者都不需要在采取任何的线程安全保障措施。
Java语言中,如果共享数据是一个基本类型数据,那么只要在定义时使用final关键字修饰它就可以保证它是不可变的。如果共享数据是一个对象,那就需要保证对象的行为不会对其状态产生任何影响才行。如String类、枚举类等(有需要继续探究的可以去看看这些类的源码),保证对象行为不影响自己状态最简单的途径就是讲对象带有状态的变量都声明为final。
绝对线程安全
绝对线程安全需要完全满足《Java Concurrency In Practice》一书对线程安全的定义。
这个定义其实是很严格的,一个类要达到“不管运行时环境如何,调用者都不要任何额外的同步措施”通常需要付出很大的代价,在Java API中标注自己是线程安全的类,大多数都不是绝对的线程安全。
相对线程安全
相对线程安全就是我们通常意义上的线程安全,它需要保证这个对象单独操作是线程安全的,我们在调用的时候不需要做额外的保障措施,但是对于一些特定顺序的联系调用,就可能需要在调用端使用额外的同步手段来保障调用的正确性。下面就展示java.util.Vector(Vector只是加了个方法锁,保证一个时间只能调用方法一次)这个线程安全的容器的不安全可能,。1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36// 错误代码
public class VectorTest {
private static Vector<Integer> vector = new Vector<>();
public static void main(String[] args) {
while (true) {
for (int i = 0; i < 10; i++) {
vector.add(i);
}
Thread removeThread = new Thread(new Runnable() {
public void run() {
for (int i = 0; i < vector.size(); i++) {
vector.remove(i);
}
}
});
Thread printThread = new Thread(new Runnable() {
public void run() {
for (int i = 0; i < vector.size(); i++) {
System.out.println(vector.get(i));
}
}
});
removeThread.start();
printThread.start();
while (Thread.activeCount() > 20);
}
}
}
运行分析:我在自己机器上没有发生异常,但是按照作者所说的是应该会出现数组越界异常的,这是因为如果另一个线程恰好在错误的时间删除了一个元素,导致序号为i已经不再可用的话,再用i访问数组就会抛出一个ArrayIndexOutOfBoundsException,如果要保证这段代码能正确执行下去,需要改成如下代码:1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40// 对vector操作加上锁
public class VectorTest {
private static Vector<Integer> vector = new Vector<>();
public static void main(String[] args) {
while (true) {
for (int i = 0; i < 10; i++) {
vector.add(i);
}
Thread removeThread = new Thread(new Runnable() {
public void run() {
synchronized (vector) {
for (int i = 0; i < vector.size(); i++) {
vector.remove(i);
}
}
}
});
Thread printThread = new Thread(new Runnable() {
public void run() {
synchronized (vector) {
for (int i = 0; i < vector.size(); i++) {
System.out.println(vector.get(i));
}
}
}
});
removeThread.start();
printThread.start();
while (Thread.activeCount() > 20);
}
}
}
在Java语言中,大部分线程安全类都属于这种类型,例如Vector、HashTable等。
线程兼容
线程兼容是指对象本身并不是线程安全的,但是可以通过在调用端正确地使用同步手段来保证对象在并发环境中可以安全使用,我们平常说的一个类不是线程安全的,绝大多数时候是指这一种情况。Java API中大部分的类都是属于线程兼容的,如与前面Vector和HashTable相对应的集合类ArrayList和HashTable等。
线程对立
线程对立是指无论调用端是否采取了同步措施,都无法再多线程环境中并发使用代码,大部分原因是会产生死锁。
线程安全的实现方法
线程安全的实现是通过代码编写以及利用虚拟机提供的同步和锁机制,而我们这主要是说一下虚拟机线程安全手段的运作过程。
互斥同步(阻塞同步)
同步是指在多个线程并发访问共享数据时,保证共享数据在同一个时刻只被一个(或者是一些,使用信号量的时候)线程使用。而互斥是实现同步的一种手段,临界区、信号量(都没用过)、互斥量都是主要的互斥实现方式。互斥是因,同步是果;互斥是方法,同步是目的。主要的互斥同步手段有下面两种:
- 使用synchronizd关键字,synchronized关键字经过编译之后,会在同步块的前后分别形成 monitorenter 和 monitorexit 这个两个字节码指令,这两个字节码都需要一个 reference类型的参数来指明要锁定和解锁的对象;如果java程序中的synchronized明确指定了对象参数,那就是这个对象的reference;如果没有明确指定,那就根据synchronized修饰的实例方法还是类方法,去取对应的对象实例或Class对象来作为锁对象。在执行monitorenter指令时,如果这个对象没有锁定或当前线程已经拥有了那个对象的锁,锁的计数器加1,相应的,在执行monitorexit指令时会将锁计数器减1;当计数器为0时,锁就被释放了。对于monitorenter 和 monitorexit的行为描述中,有两点需要注意:
- synchronized同步块对同一条线程来说是可重入的,不会出现自己把自己锁死的问题。
- 同步块在已进入的线程执行完之前,会阻塞后面其他线程的进入。
- 使用java.util.concurrent(J.U.C)包中的重入锁(ReentrantLock)。synchronized 和 ReentrantLock 的区别: 一个表现为 API 层面的互斥锁(lock() 和 unlock() 方法配合 try/finally语句块来完成),另一个表现为原生语法层面的互斥锁;ReentrantLock增加了一些高级功能主要有以下3项:
- 等待可中断:指当持有锁的线程长期不释放锁的时候,正在等待的线程可以选择放弃等待,改为处理其他事情,可中断特性对处理执行时间非常长的同步块很有帮 助 。
- 公平锁:指多个线程在等待同一个锁时,必须按照申请锁的时间顺序来依次获得锁。
- 锁绑定多个条件:指一个 ReentrantLock对象可以同时绑定多个 Condition对象,而在 synchronized中,锁对象的wait() 和 notify() 或 notifyAll() 方法可以实现一个隐含的条件,如果要和多于一个的条件关联的时候,就不得不额外地添加一个锁,而ReentrantLock 则无需这样做,只需要多次调用 newCondition() 方法即可。
- 关于两者的性能在JDK1.6以后,两者基本持平了,所以提倡在synchronized能实现需求的情况下,优先考虑使用sychronized来进行同步锁。
非阻塞同步
- 阻塞同步与非阻塞同步的对比:阻塞同步是一种悲观的并发策略,总是认为只要不去做正确的同步措施(例如加锁)就会出现问题,所以会带来进行线程阻塞和唤醒的性能问题;非阻塞同步是一种基于冲突检测的乐观的并发策略,它是先进行操作,如果没有其他线程争用共享数据,那操作就是成功的,如果共享数据有争用,产生了冲突,那就再采取其他的补偿措施(最常见的补偿措施就是不断地重试,直到成功为止)。
非阻塞同步需要硬件指令集的发展:因为需要保证操作和冲突检测这两个步骤具备原子性,而这里原子性的实现是通过一条处理器指令完成的。这类指令常用的有:
- 测试并设置
- 获取并增加
- 交换
- 比较并交换(Compare-and-set,CAS)
加载链接/条件存储
我们可以从J.U.C下得原子类的操作来证明这一点。
无同步方案
如果一个方法本来就不涉及共享数据,那它自然就无须任何同步措施去保证正确性,因此会有一些代码天生就是线程安全的。下面介绍两类线程安全代码:
- 可重入代码(纯代码):,可以在代码执行的任何时刻中断它,转而去执行另外一段代码,而在控制权返回后,原来的程序不会出现任何错误。如何判断代码是否具备可重入性:如果一个方法,它的返回结果是可以预测的,只要输入了相同的数据,就都能返回相同的结果,那它就满足可重入性的要求,当然也就是线程安全的。
- 线程本地存储:如果一段代码中所需要的数据必须与其他代码共享,那就看看这些共享数据的代码是否能够保证在同一线程中执行?如果能保证,我们就可以把共享数据的可见范围限制在同一个线程内,这样,无需同步也可以保证线程间不出现数据争用问题。
锁优化
各种锁优化技术都是为了在线程之间更加高效地共享数据,以及解决竞争问题。
自旋锁
- 为什么需要自旋锁:互斥同步对性能最大的影响是阻塞的实现,挂起线程和恢复线程的操作都需要转入内核态中完成,共享数据的锁定状态只会持续很短的一段时间,为了这段时间去挂起和恢复线程很不值得。
- 什么是自旋锁:为了让线程等待,我们只需让线程执行一个忙循环(自旋)而不放弃处理器时间,这项技术就是所谓的自旋锁。
- 自旋时间有一定限度:如果自旋超过了限定的次数仍然没有成功获得锁,就应当使用传统的方式去挂起线程了。自旋次数的默认值是10,用户可以用参数 -XX:PreBlockSpin 来更改。
- 自适应自旋锁:jdk1.6中引入了自适应的自旋锁。自适应意味着自旋的时间不再固定了,而是由前一次在同一个锁上的自旋时间及锁的拥有者的状态来决定;
锁消除
锁消除是指虚拟机即时编译器在运行时,对一些代码上要求同步,但是被检查到不可能存在共享数据竞争的锁进行消除。锁消除的主要判定依据:来源于逃逸分析的数据支持,如果判定在一段代码中,堆上的所有数据都不会逃逸出去从而被其他线程访问到,那就可以把它们当做栈上数据对待,认为它们是线程私有的,同步加锁自然就无须进行了。其中很多无用的同步措施都是Java API自带的。
锁粗化
如果一系列的连续操作都对同一个对象反复加锁和解锁,甚至加锁操作是出现在循环体中的,那即使没有线程竞争,频繁地进行互斥同步操作也会导致不必要的性能损耗。如果虚拟机探测到有这样一串零碎的操作都对同一个对象加锁,将会把加锁同步的范围扩展(粗化)到整个操作序列的外部。
轻量级锁
- 轻量级锁:使用操作系统互斥量来实现的传统锁通常被称为重量级锁,而这个轻量级锁的出现就是是在没有多线程竞争的前提下,减少传统的重量级锁使用操作系统互斥量产生的性能消耗。
- HotSpot虚拟机头Mark Word:它是实现轻量级锁和偏向锁的关键,它的内容如下表:
存储内容 | 标志位 | 转态 |
---|---|---|
对象哈希码、对象年龄分代 | 01 | 未锁定 |
指向所记录的指针 | 00 | 轻量级锁定 |
指向重量级锁的指针 | 10 | 膨胀(重量级锁定) |
空,不需要记录信息 | 11 | GC标记 |
偏向线程ID、偏向时间戳、对象分代年龄 | 01 | 可偏向 |
- 在进入同步代码块时,轻量级锁加锁过程:
- 如果此同步对象没有被锁定(锁标志位为01状态):虚拟机首先将在当前线程的栈帧中建立一个名为锁记录的空间,用于存储对象目前的Mark Word的拷贝(Displace Mark Word)。
- 然后,虚拟机将使用CAS 操作尝试将对象的 Mark Word 更新为指向Lock Record的指针。
- 如果这个更新工作成功了,那么这个线程就拥有了该对象的锁,并且对象Mark Word的锁标志位将转变为 00,即表示此对象处于轻量级锁定状态;
- 如果这个更新失败了,虚拟机首先会检查对象的Mark Word是否指向当前线程的栈帧,如果只说明当前线程已经拥有了这个对象的锁,那就可以直接进入同步块继续执行,否则说明这个锁对象以及被其他线程抢占了。如果有两条以上的线程争用同一个锁,那轻量级锁就不再有效,要膨胀为重量级锁,锁标志的状态值变为 10,Mark Word中存储的就是指向重量级(互斥量)的指针,后面等待锁的线程也要进入阻塞 状态。
- 轻量级锁解锁过程:
- 如果对象的Mark Word仍然指向着线程的锁记录,那就用CAS 操作把对象当前的Mark Word和线程中复制的 Displaced Mark Word替换回来。
- 如果替换成功,整个同步过程就完成了。
- 如果替换失败,说明有其他线程尝试过获取该锁,那就要在释放锁的同时,唤醒被挂起的线程。
- 轻量级锁能提升程序同步性能的依据是:对于绝大部分的锁,在整个同步周期内都是不存在竞争的。
偏向锁
- 偏向锁的目的:消除数据在无竞争情况下的同步原语,进一步提高程序的运行性能。如果说轻量级锁是在无竞争的情况使用CAS操作去消除同步使用的互斥量,那偏向锁就是在无竞争的情况下把整个同步都消除掉,连CAS 操作都不做了。
- 偏向锁的偏:它的意思是这个锁会偏向于第一个获得它的线程,如果在接下来的执行过程中,该锁没有被其他的线程获取,则持有偏向锁的线程将永远不需要再进行同步。
- 偏向锁过程:若当前虚拟机启用了偏向锁,那么,当锁对象第一次被线程获取的时候,虚拟机将会把对象头中的标志位设为01,即偏向模式;同时使用CAS操作把获取到这个锁的线程的ID 记录在对象的 Mark Word之中,如果CAS操作成功,持有偏向锁的线程以后每次进入这个锁相关的同步块时,虚拟机都可以不再进行任何同步操作。当有另一个线程去尝试获取这个锁时,偏向模式就结束了,根据锁对象目前是否处于被锁定的状态,撤销偏向后恢复到未锁定(标志位为01)或轻量级锁定(标志位为00)的状态,后续的同步操作就如上面介绍的轻量级锁那样执行。
- 偏向锁是一个带有效益权衡性质的优化:偏向锁可以提高带有同步但无竞争的程序性能,但是如果程序中大多数的锁总是被多个不同的线程访问,那偏向模式是多余的。
总结
关于线程安全我们可以有明确的定义,然后我们也知道了线程安全的实现方式,以及虚拟机为我们提供的各种锁优化。
参考
- 《深入理解Java虚拟机》