码迷,mamicode.com
首页 > 其他好文 > 详细

ReentrantLock

时间:2020-05-28 09:16:38      阅读:65      评论:0      收藏:0      [点我收藏+]

标签:重入   except   str   code   string   cat   ble   tst   oid   

一、将ReentrantLock和synchronized进行比较

1、synchronized和ReentrantLock都是独占锁,不同的是synchronized加锁和解锁过程自动进行;ReentrantLock需手动加锁解锁。

2、synchronized和ReentrantLock都可重入,不同的是synchronized自动进行,不必担心最后是否释放锁;但是ReentrantLock手动进行,加锁和解锁的次数需要完全一样。

可重入演示:

            synchronized (this){
                System.out.println(Thread.currentThread().getName()+" :synchronized代码块start.....");
                System.out.println(Thread.currentThread().getName()+" :synchronized代码块sleep.....");
                Thread.sleep(2000);
                System.out.println(Thread.currentThread().getName()+" :synchronized代码块voer!!!");
                synchronized (this){
                    System.out.println("重入");
                }
            }

3、相应中断:synchronized不可相应中断;ReentrantLock可以。

 

二、ReentrantLock的特性

1、简单演示

public class ReentrantLockRunnable implements Runnable{
    private ReentrantLock lock = new ReentrantLock(true);
  
    @Override
    public void run() {
        try{
            while (true){
                lock.lock();
                
                System.out.println(Thread.currentThread().getName()+"ReenTrant 已加锁");
                Thread.sleep(2000);
                System.out.println(Thread.currentThread().getName()+"sleep.....");
            }

        }catch (InterruptedException e){
            System.out.println("中断");
            e.printStackTrace();
        }finally {
                lock.unlock();
            System.out.println(Thread.currentThread().getName()+"ReenTrant 锁已释放!!!!");
        }


    }
}


import lombok.SneakyThrows;

public class ReentrantLockDemo {

    @SneakyThrows
    public static void main(String[] args){
        Runnable lock = new ReentrantLockRunnable();
        Thread thread1 = new Thread(lock);
        Thread thread2 = new Thread(lock);

        thread1.start();
        thread2.start();
    }

}

 

结果:

Thread-0ReenTrant 已加锁
Thread-0sleep.....
Thread-0ReenTrant 锁已释放!!!!
Thread-1ReenTrant 已加锁
Thread-1sleep.....
Thread-1ReenTrant 锁已释放!!!!

 

2、公平锁

线程获取锁的顺序按照调用lock方法的顺序,慎用!

private ReentrantLock lock = new ReentrantLock(true);

只需要添加true参数即可;不添加或者false参数既是不公平锁,随机获取。

3、响应中断

import java.util.concurrent.locks.ReentrantLock;

public class ReentrantLockRunnable implements Runnable{
    private ReentrantLock lock = new ReentrantLock(true);
    private static int count = 0;
    @Override
    public void run() {
        try{
            while (true){
                lock.lock();
                count++;
                System.out.println(Thread.currentThread().getName()+"ReenTrant 已加锁");
                Thread.sleep(2000);
                System.out.println(Thread.currentThread().getName()+"sleep.....");
            }

        }catch (InterruptedException e){
            System.out.println("中断");
//            e.printStackTrace();
        }finally {
            for(int i=0;i<count;i++){
                lock.unlock();
            }

            System.out.println(Thread.currentThread().getName()+"ReenTrant 锁已释放!!!!");
        }


    }
}


import lombok.SneakyThrows;

public class ReentrantLockDemo {

    @SneakyThrows
    public static void main(String[] args){
        Runnable lock = new ReentrantLockRunnable();
        Thread thread1 = new Thread(lock);
        Thread thread2 = new Thread(lock);

        thread1.start();
        thread2.start();
        Thread.sleep(5000);
        thread1.interrupt();
    }

}

结果:

Thread-0ReenTrant 已加锁
Thread-0sleep.....
Thread-0ReenTrant 已加锁
Thread-0sleep.....
Thread-0ReenTrant 已加锁
中断
Thread-0ReenTrant 锁已释放!!!!
Thread-1ReenTrant 已加锁
Thread-1sleep.....
Thread-1ReenTrant 已加锁
Thread-1sleep.....
Thread-1ReenTrant 已加锁
Thread-1sleep.....
Thread-1ReenTrant 已加锁
Thread-1sleep.....
。。。。。持续运行

上述代码中加锁几次释放几次,现在把finally中的代码修改:

finally {
            
            lock.unlock();
            System.out.println(Thread.currentThread().getName()+"ReenTrant 锁已释放!!!!");
        }

结果:

Thread-0ReenTrant 已加锁
Thread-0sleep.....
Thread-0ReenTrant 已加锁
Thread-0sleep.....
Thread-0ReenTrant 已加锁
中断
Thread-0ReenTrant 锁已释放!!!!

Thread-1线程无法进入继续运行,因为锁没有完全释放。加了三次锁,只释放了两次。

5、限时等待

使用tryLock带替lock,设置等待时间,如果取得锁则返回true,如果没有取得则返回false。无参默认不等待,直接返回结果。

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;

public class ReentrantLockDome2 implements Runnable{
    private ReentrantLock lock = new ReentrantLock();

    @Override
    public void run() {

        try{
            if (lock.tryLock(1, TimeUnit.SECONDS)){
                System.out.println(Thread.currentThread().getName()+": 已加锁!");
                
                System.out.println(Thread.currentThread().getName()+": sleep....");
                TimeUnit.SECONDS.sleep(5);
            }else{
                System.out.println(Thread.currentThread().getName()+": come here!");
                System.out.println(Thread.currentThread().getName()+": over!");
            }
        }catch (InterruptedException e){
            System.out.println(Thread.currentThread().getName()+":中断");
        }finally {
            if(lock.isHeldByCurrentThread()){//此锁是否由当前线程持有
                lock.unlock();
                System.out.println(Thread.currentThread().getName()+": 释放锁!");
            }

        }


    }

    public static void main(String[] args){
        ReentrantLockDome2 reentrantLockDome2 = new ReentrantLockDome2();
        Thread thread1 = new Thread(reentrantLockDome2);
        Thread thread2 = new Thread(reentrantLockDome2);

        thread1.start();
        thread2.start();

    }
}

结果:

Thread-0: 已加锁!
Thread-0: sleep....
Thread-1: come here!
Thread-1: over!
Thread-0: 释放锁!

 

lock.lock();

ReentrantLock

标签:重入   except   str   code   string   cat   ble   tst   oid   

原文地址:https://www.cnblogs.com/whalesea/p/12977766.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!