美文网首页
【Java并发编程实战】-----synchronized

【Java并发编程实战】-----synchronized

作者: lucode | 来源:发表于2017-10-18 18:08 被阅读3次

多线程共享内存的两个问题,一个是竞态条件,另一个是内存可见性,解决这两个问题的一个方案是使用synchronized关键字

用法

synchronized可以用于修饰类的实例方法、静态方法和代码块。
部分人说是两种方式,其实这里面修饰实例方法和静态方法是不一样的。下面我会详细解释。

实例方法

public class Counter {
    private int count;
    public synchronized void incr(){
        count ++;
    }
    public synchronized int getCount() {
        return count;
    }
}

Counter是一个简单的计数器类,incr方法和getCount方法都加了synchronized修饰。加了synchronized后,方法内的代码就变成了原子操作,当多个线程并发更新同一个Counter对象的时候,也不会出现问题,我们看使用的代码:

public class CounterThread extends Thread {
    Counter counter;
    public CounterThread(Counter counter) {
        this.counter = counter;
    }
    @Override
    public void run() {
        try {
            Thread.sleep((int) (Math.random() * 10));
        } catch (InterruptedException e) {
        }
        counter.incr();
    }
  public static void main(String[] args) throws InterruptedException{
        int num = 100;
        Counter counter = new Counter();
        Thread[] threads = new Thread[num];
        for (int i = 0; i < num; i++) {
      // 创建100个线程 赋值同样的计数器对象
            threads[i] = new CounterThread(counter);
            threads[i].start();
        }
        for (int i = 0; i < num; i++) {
            threads[i].join();
        }
        System.out.println(counter.getCount());
    }
}

运行结果肯定能达到预期的
下面这段

Counter counter1 = new Counter();
Counter counter2 = new Counter();
Thread t1 = new CounterThread(counter1);
Thread t2 = new CounterThread(counter2);
t1.start();
t2.start();

这里,t1和t2两个线程是可以同时执行Counter的incr方法的,因为它们访问的是不同的Counter对象,一个是counter1,另一个是counter2。不存在竞态条件。

所以,synchronized实例方法实际保护的是同一个对象的方法调用,确保同时只能有一个线程执行。再具体来说,synchronized实例方法保护的是当前实例对象,即this,this对象有一个锁和一个等待队列,锁只能被一个线程持有,其他试图获得同样锁的线程需要等待,执行synchronized实例方法的过程大概如下:

    1. 尝试获得锁,如果能够获得锁,继续下一步,否则加入等待队列,阻塞并等待唤醒
    1. 执行实例方法体代码
    1. 释放锁,如果等待队列上有等待的线程,从中取一个并唤醒,如果有多个等待的线程,唤醒哪一个是不一定的,不保证公平性

更加深入的理解
当前线程不能获得锁的时候,它会加入等待队列等待,线程的状态会变为BLOCKED(堵塞)。
synchronized保护的是对象而非代码,只要访问的是同一个对象的synchronized方法,即使是不同的代码,也会被同步顺序访问,比如,对于Counter中的两个实例方法getCount和incr,对同一个Counter对象,一个线程执行getCount,另一个执行incr,它们是不能同时执行的,会被synchronized同步顺序执行。
此外,需要说明的,synchronized方法不能防止非synchronized方法被同时执行,比如,如果给Counter类增加一个非synchronized方法:

public void decr(){
    count --;
}

则该方法可以和synchronized的incr方法同时执行,这通常会出现非期望的结果,所以,一般在保护变量时,需要在所有访问该变量的方法上加上synchronized。

静态方法

public class StaticCounter {
    private static int count = 0;
    public static synchronized void incr() {
        count++;
    }
    public static synchronized int getCount() {
        return count;
    }
}

synchronized保护的是对象,对实例方法,保护的是当前实例对象this,对静态方法,保护的是哪个对象呢?是类对象,这里是StaticCounter.class,实际上,每个对象都有一个锁和一个等待队列,类对象也不例外。

synchronized静态方法和synchronized实例方法保护的是不同的对象,不同的两个线程,可以同时,一个执行synchronized静态方法,另一个执行synchronized实例方法。

代码块

public class Counter {
    private int count;
    public void incr(){
        synchronized(this){
            count ++;    
        }
    }
    public int getCount() {
        synchronized(this){
            return count;
        }
    }
}

synchronized括号里面的就是保护的对象,对于实例方法,就是this,{}里面是同步执行的代码。
对于前面的StaticCounter类(静态方法),等价的代码为:

public class StaticCounter {
    private static int count = 0;
    public static void incr() {
        synchronized(StaticCounter.class){
            count++;    
        }    
    }
    public static int getCount() {
        synchronized(StaticCounter.class){
            return count;    
        }
    }
}

进一步理解 synchronized

  • 可重入性
  • 内存可见性
  • 死锁

可重入性

synchronized有一个重要的特征,它是可重入的,也就是说,对同一个执行线程,它在获得了锁之后,在调用其他需要同样锁的代码时,可以直接调用,比如说,在一个synchronized实例方法内,可以直接调用其他synchronized实例方法。可重入是一个非常自然的属性,应该是很容易理解的,之所以强调,是因为并不是所有锁都是可重入的,后面具体研究。

可重入是通过记录锁的持有线程和持有数量来实现的,当调用被synchronized保护的代码时,检查对象是否已被锁,如果是,再检查是否被当前线程锁定,如果是,增加持有数量,如果不是被当前线程锁定,才加入等待队列,当释放锁时,减少持有数量,当数量变为0时才释放整个锁。

内存可见性

对于复杂一些的操作,synchronized可以实现原子操作,避免出现竞态条件,但对于明显的本来就是原子的操作方法,也需要加synchronized吗?比如说,对于下面的开关类Switcher,它只有一个boolean变量on和对应的setter/getter方法:

public class Switcher {
    private boolean on;
    public boolean isOn() {
        return on;
    }
    public void setOn(boolean on) {
        this.on = on;
    }
}

当多线程同时访问同一个Switcher对象时,会有问题吗?没有竞态条件问题,但正如上节所说,有内存可见性问题,而加上synchronized可以解决这个问题。
synchronized除了保证原子操作外,它还有一个重要的作用,就是保证内存可见性,在释放锁时,所有写入都会写回内存,而获得锁后,都会从内存中读最新数据。
不过,如果只是为了保证内存可见性,使用synchronzied的成本有点高,有一个更轻量级的方式,那就是给变量加修饰符volatile,如下所示:

public class Switcher {
    private volatile boolean on;
    public boolean isOn() {
        return on;
    }
    public void setOn(boolean on) {
        this.on = on;
    }
}

加了volatile之后,Java会在操作对应变量时插入特殊的指令,保证读写到内存最新值,而非缓存的值。

死锁

使用synchronized或者其他锁,要注意死锁,所谓死锁就是类似这种现象,比如, 有a, b两个线程,a持有锁A,在等待锁B,而b持有锁B,在等待锁A,a,b陷入了互相等待,最后谁都执行不下去

还有一种方法是使用显式锁接口Lock(以后研究),它支持尝试获取锁(tryLock)和带时间限制的获取锁方法,使用这些方法可以在获取不到锁的时候释放已经持有的锁,然后再次尝试获取锁或干脆放弃,以避免死锁。

如果还是出现了死锁,怎么办呢?Java不会主动处理,不过,借助一些工具,我们可以发现运行中的死锁,比如,Java自带的jstack命令会报告发现的死锁。

相关文章

网友评论

      本文标题:【Java并发编程实战】-----synchronized

      本文链接:https://www.haomeiwen.com/subject/rqchuxtx.html