欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Java并发编程系列之Lock与synchronized

程序员文章站 2022-05-05 09:41:12
...

Lock与synchronized 的区别

1、lock是可中断锁,支持中断处理,而synchronized 不是可中断锁

线程A和B都要获取对象O的锁定,假设A获取了对象O锁,B将等待A释放对O的锁定,
如果使用 synchronized ,如果A不释放,B将一直等下去,不能被中断
如果使用ReentrantLock,如果A不释放,可以使B在等待了足够长的时间以后,中断等待,而干别的事情

ReentrantLock获取锁定的三种方式:

a) lock(), 如果获取了锁立即返回,如果别的线程持有锁,当前线程则一直处于休眠状态,直到获取锁

b) tryLock(), 如果获取了锁立即返回true,如果别的线程正持有锁,立即返回false;

c) tryLock(long timeout,TimeUnit unit), 如果获取了锁定立即返回true,如果别的线程正持有锁,会等待参数给定的时间,在等待的过程中,如果获取了锁定,就返回true,如果等待超时,返回false;

d) lockInterruptibly():如果获取了锁定立即返回,如果没有获取锁定,当前线程处于休眠状态,直到或者锁定,或者当前线程被别的线程中断

2、synchronized是在JVM层面上实现的,lock是通过代码实现的,JVM会自动释放锁定(代码执行完成或者出现异常),但是使用Lock则不行,要保证锁定一定会被释放,就必须将unLock()放到finally{}中。

3、在资源竞争不是很激烈的情况下,synchronized的性能要优于ReetrantLock,但是在资源竞争很激烈的情况下,Synchronized的性能会下降几十倍,但是ReentrantLock的性能能维持常态;

4、与synchronized相比,ReentrantLock提供了更多,更加全面的功能,具备更强的扩展性。例如:时间锁等候,可中断锁等候,锁投票。

5、ReentrantLock还提供了条件Condition,对线程的等待、唤醒操作更加详细和灵活,所以在多个条件变量和高度竞争锁的地方,ReentrantLock更加适合(以后会阐述Condition)。

6、ReentrantLock提供了可轮询的锁请求。它会尝试着去获取锁,如果成功则继续,否则可以等到下次运行时处理,而synchronized则一旦进入锁请求要么成功要么阻塞,所以相比synchronized而言,ReentrantLock会不容易产生死锁些。

7、ReentrantLock支持更加灵活的同步代码块,但是使用synchronized时,只能在同一个synchronized块结构中获取和释放。注:ReentrantLock的锁释放一定要在finally中处理,否则可能会产生严重的后果。

Lock的使用

Jdk1.5中,在java.util.concurrent.locks包下,有一组实现线程同步的接口和类,说到线程的同步,很多立马就会想到synchronized关键字,这是java内置的关键字,用来处理线程同步的,但这个关键字有很多的缺陷,使用起来也不是很方便和直观,所以就出现了Lock,下面,我们就来对比着讲解Lock。

synchronized关键字在使用的过程中会有如下几个问题:

1、不可控性,无法做到随心的加锁和释放锁

2、效率比较低下,比如我们现在并发的读两个文件,读与读之间是互不影响的,但如果给这个读的对象使用synchronized来实现同步的话,那么只要有一个线程进入了,那么其他的线程都要等待。

3、无法知道线程是否获取到了锁

以上问题,Lock都可以很好的解决,并且jdk1.5还提供了各种锁,例如读写锁,但有一点需要注意,使用synchronized关键时,无须手动释放锁,但使用Lock必须手动释放锁。下面我们就来学习一下Lock锁。

java.util.concurrent.locks.Lock是一个上层的接口,其原型如下,总共提供了6个方法:

public interface Lock {
    // 用来获取锁,如果锁已经被其他线程获取,则一直等待,直到获取到锁
    void lock();

    // 该方法获取锁时,可以响应中断,比如现在有两个线程,一个已经获取到了锁,另一个线程调用这个方法正在等待锁,
    // 但是此刻又不想让这个线程一直在这死等,可以通过调用线程的Thread.interrupted()方法,来中断线程的等待过程
    void lockInterruptibly() throws InterruptedException;

    // tryLock方法会返回bool值,该方法会尝试着获取锁,如果获取到锁,就返回true,如果没有获取到锁,就返回false,但是该方法会立刻返回,而不会一直等待
    boolean tryLock();

    // 这个方法和上面的tryLock差不多是一样的,只是会尝试指定的时间,如果在指定的时间内拿到了锁,则会返回true,如果在指定的时间内没有拿到锁,则会返回false
    boolean tryLock(long time, TimeUnit unit) throws InterruptedException;

    // 释放锁
    void unlock();

    // 实现线程通信,相当于wait和notify,后面会单独讲解
    Condition newCondition();
}

那么这几个方法该如何使用了?前面我们说到,使用Lock是需要手动释放锁的,但是如果程序中抛出了异常,那么就无法做到释放锁,有可能引起死锁,所以我们在使用Lock的时候,有一种固定的格式,如下:

// 下面这段代码摘自官方文档  
Lock l = ...;  
l.lock();  
try {  
    // access the resource protected by this lock  
} finally {// 必须使用try,最后在finally里面释放锁  
    l.unlock();  
}  

下面我们来看一个简单的例子,代码如下:

/**
 * 描述:Lock使用
 */
public class LockDemo {
    // new一个锁对象,注意此处必须声明成类对象,保持只有一把锁,ReentrantLock是Lock的唯一实现类
    Lock lock = new ReentrantLock();

    public void readFile(String fileMessage) {
        lock.lock();// 上锁
        try {
            System.out.println(Thread.currentThread().getName() + "得到了锁,正在读取文件……");
            for (int i = 0; i < fileMessage.length(); i++) {
                System.out.print(fileMessage.charAt(i));
            }
            System.out.println();
            System.out.println("文件读取完毕!");
        } finally {
            System.out.println(Thread.currentThread().getName() + "释放了锁!");
            lock.unlock();
        }
    }

    public void demo(final String fileMessage) {
        // 创建若干个线程
        ExecutorService service = Executors.newCachedThreadPool();
        // 提交20个任务
        for (int i = 0; i < 20; i++) {
            service.execute(new Runnable() {
                @Override
                public void run() {
                    readFile(fileMessage);
                    try {
                        Thread.sleep(20);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            });
        }
        // 释放线程池中的线程
        service.shutdown();
    }

    public static void main(String[] args) {
        LockDemo demo = new LockDemo();
        demo.demo("Hello World");
    }
}

我们先把锁的那两行代码注释掉,看下效果如何:

Java并发编程系列之Lock与synchronized

然后我们把锁的代码加上,看下效果如何:

Java并发编程系列之Lock与synchronized

如果我们把上面的readFile方法前面加上synchronized关键字,然后把锁去掉,效果是一样的。

tryLock锁的使用和Lock锁的使用类似,下面把示例代码贴出来,就不做过多的说明了,代码如下:

/**
 * 描述:TryLock使用
 */
public class TryLockDemo {
    // new一个锁对象
    Lock lock = new ReentrantLock();

    public void readFile(String fileMessage) {
        if (lock.tryLock()) {
            try {
                System.out.println(Thread.currentThread().getName() + "得到了锁,正在读取文件……");
                System.out.println("文件读取完毕!");
            } finally {
                System.out.println(Thread.currentThread().getName() + "释放了锁!");
                lock.unlock();
            }
        } else {
            System.out.println(Thread.currentThread().getName() + "获取锁失败!");
        }
    }

    public void demo(final String fileMessage) {
        // 创建若干个线程
        ExecutorService service = Executors.newCachedThreadPool();
        // 提交200个任务
        for (int i = 0; i < 200; i++) {
            service.execute(new Runnable() {
                @Override
                public void run() {
                    readFile(fileMessage);
                }
            });
        }
        // 释放线程池中的线程
        service.shutdown();
    }

    public static void main(String[] args) {
        TryLockDemo demo = new TryLockDemo();
        demo.demo("Hello World");
    }
}

测试效果如下:

Java并发编程系列之Lock与synchronized


参考文档:
1. https://blog.csdn.net/fighterandknight/article/details/54906507
2. https://blog.csdn.net/fighterandknight/article/details/54945559

相关标签: Lock synchronized