锁单从字面来讲,决定进与出,上了锁,则拒绝进入。而在程序中,指的是拒绝线程的进入。
上锁的目的是解决多线程对资源竞争产生的数据不一致,总而言之上锁的过程是针对临界区代码的同步,例如线程A拿到锁则同步资源由线程A占领,其它线程进行挂起或排队等待锁的释放。
在Java中,我们一般会将锁分为悲观与乐观、可重入与不可重入、公平与非公平和共享与独占等。这只是在不同角度对于锁的划分,并不是表示一种锁的唯一归属,比如synchronized它是一种悲观锁,可重入且非公平的。ReentrantLock也是悲观锁,可重入且公平的(也支持非公平)
关于锁的具体分类和不同场景下的使用,可以看看这篇我转载的文章
>>Java基础学习之并发篇:不同的锁的适用场景
加锁是有代价的,加锁通常会严重地影响性能。阻塞或唤醒一个Java线程需要操作系统切换CPU状态来完成,这种状态转换需要耗费处理器时间。如果同步代码块中的内容过于简单,状态转换消耗的时间有可能比用户代码执行的时间还要长,或者如果一个线程在持有锁的情况下被延迟执行,例如发生了缺页错误、调度延迟或者其它类似情况,那么所有需要这个锁的线程都无法执行下去。这种方式就是synchronized最初实现同步的方式,这就是JDK 6之前synchronized效率低的原因。这种依赖于操作系统Mutex Lock所实现的锁我们称之为“重量级锁”,JDK 6中为了减少获得锁和释放锁带来的性能消耗,所以对加锁过程作了一些优化引入了“偏向锁”和“轻量级锁”。
所以锁的使用是一把双刃剑,保证多线程下的资源同步,但又会有性能方面的考量,所以大家一直在追求使用锁过程的不断优化,甚至追求无锁编程
synchronized
是 Java 中的关键字,是利用锁的机制来实现同步的,保证资源的同步性。synchronized
可以作用于普通方法上,静态方法上和代码块中,例如:
/** * synchronized作用在普通方法中 * @return */ public synchronized String hello(){ return "hello synchronized method"; }
/** * synchronized作用在静态方法中 * @return */ public synchronized static String helloStaticMethod(){ return "hello synchronized method"; }
synchronized (this) { try { Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("finished."); }
synchronized 可以修饰方法和代码块
修饰代码块
synchronized(this|object) {}
synchronized(类.class) {}
修饰方法
修饰非静态方法
修饰静态方法
在不同场景下使用到的锁是:
可以总结如下:
正如我们上面提到的,Java团队一直在追求对synchronized的优化,例如引入偏向锁、轻量级锁,弄清楚优化的过程,我们要明白synchronized实现的方式:
synchronized通过Monitor来实现线程同步,Monitor是依赖于底层的操作系统的Mutex Lock(互斥锁)来实现的线程同步,之所以任何对象能够充当锁,在于Java在对象中有个Mark Word(标记字段)、Klass Pointer(类型指针)。
Mark Word:默认存储对象的HashCode,分代年龄和锁标志位信息。这些信息都是与对象自身定义无关的数据,所以Mark Word被设计成一个非固定的数据结构以便在极小的空间内存存储尽量多的数据。它会根据对象的状态复用自己的存储空间,也就是说在运行期间Mark Word里存储的数据会随着锁标志位的变化而变化。
Klass Point:对象指向它的类元数据的指针,虚拟机通过这个指针来确定这个对象是哪个类的实例。
每个线程拥有Monitor变量,关联锁Mark Word
信息。Monitor拥有Owner确认当前自己是否是该锁的拥有者。也就是说一个线程在去竞争锁时,找到当前锁Mark Word
发现锁的状态,当前锁拥有者,锁是否释放等信息。
以下是锁升级的过程:
偏向锁
状态轻量级锁
,线程B此时自旋去等待线程A释放锁,如果在自旋一定次数后,拿到了锁那么此时算比较走运重量级锁
,重量级锁就是需要CPU的唤醒嘛,有点浪费时间我们在直接用synchronized时感觉用的还是不爽,某个线程tm程序炸了一直占用,导致其它线程全部失效,还要自己去实现个定时去超时处理。中断也不能及时响应,即使中断了还是在搞事情。所以Java团队听到了你们的心声,弄了一个Lock,老哥们拿去用吧。
Lock是在1.5之后提供的一个独占锁接口,它的实现类是ReentrantLock,相比较synchronized这种隐式锁(不用手动加锁和释放锁)的便捷性,但是提供了更加锁的可操作性、可中断的获取锁以及超时获取锁等多种synchronized不具备的特性
使用方法如下:
ReentrantLock lock = new ReentrantLock(); lock.lock(); try { lock.lock(); } catch (InterruptedException e) { e.printStackTrace(); } finally { lock.unlock(); }
设置超时时间
Thread t = new Thread(() -> { try { lock.tryLock(1000, TimeUnit.MICROSECONDS); Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } finally { lock.unlock(); } }); t.start(); // 中断线程会立即响应 t.interrupt();
java.lang.InterruptedException at java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireNanos(AbstractQueuedSynchronizer.java:1245) at java.util.concurrent.locks.ReentrantLock.tryLock(ReentrantLock.java:442) at SynchronizedKeyWords.lambda$main$0(SynchronizedKeyWords.java:14) at java.lang.Thread.run(Thread.java:748)
使用的很爽了,那么里面的实现和synsychronized到底有啥区别,不得不要去瞄一下:
public class ReentrantLock implements Lock, java.io.Serializable { private static final long serialVersionUID = 7373984872572414699L; /** Synchronizer providing all implementation mechanics */ private final Sync sync; abstract static class Sync extends AbstractQueuedSynchronizer { private static final long serialVersionUID = -5179523762034025860L; abstract void lock(); final boolean nonfairTryAcquire(int acquires) { } protected final boolean tryRelease(int releases) { } } /** * Sync object for non-fair locks */ static final class NonfairSync extends Sync { private static final long serialVersionUID = 7316153563782823691L; /** * Performs lock. Try immediate barge, backing up to normal * acquire on failure. */ final void lock() { if (compareAndSetState(0, 1)) setExclusiveOwnerThread(Thread.currentThread()); else acquire(1); } protected final boolean tryAcquire(int acquires) { return nonfairTryAcquire(acquires); } } /** * Sync object for fair locks */ static final class FairSync extends Sync { private static final long serialVersionUID = -3000897897090466540L; final void lock() { acquire(1); } /** * Fair version of tryAcquire. Don't grant access unless * recursive call or no waiters or is first. */ protected final boolean tryAcquire(int acquires) { } } }
发现了一些好东西,ReentrantLock类实现接口Lock,抽象内部类Sync继承AQS(AbstractQueuedSynchronizer),有公平和非公平的两个实现类继承自Sync。