前言
上一节讲了i++并不是线程安全的,我们需要用synchronized来保证其线程安全。
这里我就介绍下synchronized的基本用法和简单原理。
便于说明,我写了个i++的例子:
public class AddI {
public static volatile int i = 0;
public static void main(String[] args) throws InterruptedException {
Thread t1 = new Thread(() -> add(1000000));
Thread t2 = new Thread(() -> add(1000000));
t1.start();
t2.start();
t1.join();
t2.join();
System.out.println(i);
}
public static void add(int n) {
for (int m = 0; m < n; m++) {
i++;
}
}
}
1、什么时候加锁呢?
没有共享就没有伤害,比如上面的i++被2个线程同时修改,出现了并发问题。此时我们就需要进行加锁。
如果一个变量没有共享,且没有并发问题,那加锁只会降低程序的性能。
线程安全是并发编程中的重要关注点,应该注意到的是,造成线程安全问题的主要诱因有两点,一是存在共享数据(也称临界资源),二是存在多条线程共同操作共享数据。
因此为了解决这个问题,我们可能需要这样一个方案,当存在多个线程操作共享数据时,需要保证同一时刻有且只有一个线程在操作共享数据,其他线程必须等到该线程处理完数据后再进行,这种方式有个高尚的名称叫互斥锁,即能达到互斥访问目的的锁,也就是说当一个共享数据被当前正在访问的线程加上互斥锁后,在同一个时刻,其他线程只能处于等待的状态,直到当前线程处理完毕释放该锁。
在 Java 中,关键字 synchronized可以保证在同一个时刻,只有一个线程可以执行某个方法或者某个代码块(主要是对方法或者代码块中存在共享数据的操作),同时我们还应该注意到synchronized另外一个重要的作用,synchronized可保证一个线程的变化(主要是共享数据的变化)被其他线程所看到(保证可见性,完全可以替代Volatile功能),这点确实也是很重要的。
2、Synchronized三种应用方式
常见的用法:
class X {
// 方式一:修饰非静态方法
synchronized void foo() {
// 临界区
}
// 方式二:修饰静态方法
synchronized static void bar() {
// 临界区
}
// 方式三:修饰代码块
Object obj = new Object();
void baz() {
synchronized(obj) {
// 临界区
}
}
}
在java里面使用synchronized,加锁lock和解锁unlock这2个操作是Java默认加上的,Java 编译器会在 synchronized 修饰的方法或代码块前后自动加上加锁 lock() 和解锁 unlock(),这样做的好处就是加锁 lock() 和解锁 unlock() 一定是成对出现的,毕竟忘记解锁 unlock() 可是个致命的 Bug。
那 synchronized 里的加锁 lock() 和解锁 unlock() 锁定的对象在哪里呢?上面的代码我们看到只有修饰代码块的时候,锁定了一个 obj 对象,那修饰方法的时候锁定的是什么呢?这个也是 Java 的一条隐式规则:
- 当修饰静态方法的时候,锁定的是当前类的 Class 对象,在上面的例子中就是 Class X;
- 当修饰非静态方法的时候,锁定的是当前实例对象 this。
对于上面的例子,synchronized 修饰静态方法相当于:
class X {
// 修饰静态方法
synchronized(X.class) static void bar() {
// 临界区
}
}
修饰非静态方法,相当于:
class X {
// 修饰非静态方法
synchronized(this) void foo() {
// 临界区
}
}
这里把i++的例子改下就没有并发问题了:
public class AddI {
public static volatile int i = 0;
Object object = new Object();// 单独new一个对象 用于加锁
public static void main(String[] args) throws InterruptedException {
// 方式一:修饰静态方法
Thread t1 = new Thread(() -> add(1000000));
Thread t2 = new Thread(() -> add(1000000));
// 方式二:修饰普通方法
/*AddI addI = new AddI();
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
addI.add2(1000000);
}
});
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
addI.add2(1000000);
}
});*/
// 方式三
/*AddI addI = new AddI();
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
addI.add3(1000000);
}
});
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
addI.add3(1000000);
}
});*/
t1.start();
t2.start();
t1.join();
t2.join();
System.out.println(i);
}
// 修饰静态方法
public static synchronized void add1(int n) {
for (int m = 0; m < n; m++) {
i++;
}
}
// 修饰普通方法
public synchronized void add2(int n) {
for (int m = 0; m < n; m++) {
i++;
}
}
// 代码块加锁
public void add3(int n) {
synchronized (object) {
for (int m = 0; m < n; m++) {
i++;
}
}
}
}
synchronized 是 Java 在语言层面提供的互斥原语,其实 Java 里面还有很多其他类型的锁,但作为互斥锁,原理都是相通的:锁,一定有一个要锁定的对象,至于这个锁定的对象要保护的资源以及在哪里加锁 / 解锁,就属于设计层面的事情了。
加锁本质就是在锁的对象的对象头中写入当前线程id(这涉及到底层的东西,后面我也整理一篇)。
沪漂程序员一枚。
坚持写博客,如果觉得还可以的话,给个小星星哦,你的支持就是我创作的动力。
个人微信公众号:“Java尖子生”,阅读更多干货。
关注公众号,领取学习、面试资料。加技术讨论群。