synchronized 方法
private synchronized void count(int newValue) {
x = newValue;
y = newValue;
if (x != y) {
System.out.println("x: " + x + ", y:" + y);
}
}
synchronized 代码块
private void count(int newValue) {
synchronized (this) {
x = newValue; y = newValue; if (x != y) {
System.out.println("x: " + x + ", y:" + y);
}
}
}
synchronized (monitor1) {
synchronized (monitor2) {
name = x + "-" + y;
}
}
synchronized 的本质
保证方法内部或代码块内部资源(数据)的互斥访问。即同一时间、由同一个
Monitor 监视的代码,最多只能有一个线程在访问
保证线程之间对监视资源的数据同步。即,任何线程在获取到 Monitor 后的第一时间,会先将共享内存中的数据复制到自己的缓存中;任何线程在释放 Monitor 的第一时间,会先将缓存中的数据复制到共享内存中。
volatile
保证加了 volatile 关键字的字段的操作具有原子性和同步性,其中原子性相当于实现了针对单一字段的线程间互斥访问。因此 volatile 可以看做是简化版的 synchronized。
volatile 只对基本类型 (byte、char、short、int、long、float、double、boolean) 的赋值操作和对象的引用赋值操作有效。
java.util.concurrent.atomic 包:
保证加了 volatile 关键字的字段的操作具有原子性和同步性,其中原子性相当于实现了针对单一字段的线程间互斥访问。因此 volatile 可以看做是简化版的 synchronized。
volatile 只对基本类型 (byte、char、short、int、long、float、double、boolean) 的赋值操作和对象的引用赋值操作有效。
java.util.concurrent.atomic 包:
下面有
通用版的 volatile。
omicInteger atomicInteger = new AtomicInteger(0);
atomicInteger.getAndIncrement();
Lock / ReentrantReadWriteLock
同样是「加锁」机制。但使用方式更灵活,同时也更麻烦一些。
Lock lock = new ReentrantLock();
lock.lock();
try {
x++;
} finally {
lock.unlock();
}
finally 的作用:保证在方法提前结束或出现 Exception 的时候,依然能正常释放锁。
ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
Lock readLock = lock.readLock(); Lock writeLock = lock.writeLock();
private int x = 0;
private void count() {
writeLock.lock(); try {
x++;
} finally {
writeLock.unlock();
}
}
private void print(int time) {
readLock.lock(); try {
for (int i = 0; i < time; i++) { System.out.print(x + " ");
}
System.out.println();
} finally {
readLock.unlock();
}
}
线程安全问题的本质:
在多个线程访问共同的资源时,在某一个线程对资源进行写操作的中途(写入已经开始,但还没 结束),其他线程对这个写了一半的资源进行了读操作,或者基于这个写了一半的资源进行了写 操作,导致出现数据错误。
锁机制的本质:
通过对共享资源进行访问限制,让同一时间只有一个线程可以访问资源,保证了数据的准确性。
不论是线程安全问题,还是针对线程安全问题所衍生出的锁机制,它们的核心都在于共享的资 源,而不是某个方法或者某几行代码。