public class LockTest { // 新建锁 Lock lock = new ReentrantLock(); public static void main(String[] args) { // 测试 LockTest test = new LockTest(); test.te(); } public void te(){ try { // 获取锁 lock.lock(); System.out.println("获取到锁执行代码!"); } catch (Exception e) { e.printStackTrace(); } finally { // 必定注意 在finally中释放锁 lock.unlock(); } } }
Lock比synchronized仍是多一些功能的,好比能够设置规定时间内获取不到锁就返回,不一直阻塞。java
一个不合时宜的例子就是:测试
synchronize就是一个舔狗,一直舔 直到天荒地老spa
lock 的 tryLock 就像是一个渣男,轻轻尝试一下,不合适抓紧下一个code
public class LockTest02 { // 新建锁 Lock lock = new ReentrantLock(); public static void main(String[] args) { // 测试 LockTest02 test = new LockTest02(); new Thread(()->test.te()).start(); // test::teTryLock lambda写法 new Thread(test::teTryLock).start(); } private void teTryLock() { boolean res = false; try { // 尝试获取 5秒钟获取不到就结束 res = lock.tryLock(5,TimeUnit.SECONDS); if (res) { System.out.println("teTryLock获取到锁了,执行获取到锁的代码"); } else{ System.out.println("teTryLock没有获取到锁 执行没有获取到锁的代码"); } } catch (Exception e) { e.printStackTrace(); } finally { // 若是获取到锁了 再释放 if (res) { lock.unlock(); } } } public void te(){ try { // 获取锁 lock.lock(); System.out.println("te获取到锁执行代码!"); Thread.sleep(10000); } catch (Exception e) { e.printStackTrace(); } finally { // 必定注意 在finally中释放锁 lock.unlock(); System.out.println("te释放锁!"); } } } 输出结果: te获取到锁执行代码! teTryLock没有获取到锁 执行没有获取到锁的代码 te释放锁!
synchronized 若是开始等待是不能结束的队列
可是Lock使用lockInterruptibly 能够被中断 在异常捕获里捕获异常 而后作一些后置处理源码
public class LockTest03 { // 新建锁 Lock lock = new ReentrantLock(); public static void main(String[] args) throws InterruptedException { // 测试 LockTest03 test = new LockTest03(); new Thread(test::te).start(); Thread thread = new Thread(test::teLockInterruptibly); thread.start(); Thread.sleep(3000); thread.interrupt(); } private void teLockInterruptibly() { boolean res = true; try { // 尝试获取 5秒钟获取不到就结束 lock.lockInterruptibly(); System.out.println("获取到锁··"); } catch (InterruptedException e) { //没有正常获取锁 被Interrupt了 res = false; System.out.println("InterruptedException:被打断了 作一些其余处理"); } finally { // 若是没被打断 是正常获取锁的(理论上是,也可能有其余异常) if(res) { lock.unlock(); } } } public void te(){ try { // 获取锁 lock.lock(); System.out.println("te获取到锁执行代码!"); // te 方法睡死过去了 Thread.sleep(10000000); } catch (Exception e) { e.printStackTrace(); } finally { // 必定注意 在finally中释放锁 lock.unlock(); System.out.println("te释放锁!"); } } }
synchronized是非公平锁 后来的也可能会先获取到锁 it
Lock锁默认也是非公平锁 io
非公平锁是什么样的?class
用不要脸的小强来作比喻,假设有10我的在排队买饼,小强这时候也来买饼了,不要脸的他直接跑第一个位置,这时候若是正有人在选饼,那他就灰溜溜的走了,若是上一我的恰好买完,下一我的尚未开始选,那不要脸的小强就会趁着这个间隙直接跟老板选饼. 这样对于后边排队的是不公平的 因此称为不公平锁thread
在ReentrantLock的实现中,不要脸的小强会尝试好几回,最后都失败的话他才会去队尾排队
Lock能够实现公平锁:公平锁就是lock的时候会先去排队队列里边看看,有没有人在排队,有的话站后边去,能够看我写过的AQS ,用公平锁作的举例 讲到了源码层
注意:公平锁不是彻底公平,公平锁只是会检查队列里有没有人排队,若是没有本身去申请锁,若是有本身去排队,去检查有没有人排队的时候可能会出现不公平(地铁一我的一大步窜你前边了),进队列的时候也可能会出现不公平(地铁一我的一大步窜你前边了)
Lock lock = new ReentrantLock(true); // true表示公平
有问题能够留言哦,也能够公众号留言(回复快):