简要答案: 1.Lock能完成几乎所有synchronized的功能,并有一些后者不具备的功能,如锁投票、定时锁等候、可中断锁等候等 2.synchronized 是Java 语言层面的,是内置的关键字;Lock 则是JDK 5中出现的一个包,在使用时,synchronized 同步的代码块可以由JVM自动释放;Lock 需要程序员在finally块中手工释放,如果不释放,可能会引起难以预料的后果(在多线程环境中)。
synchronized 快速回顾: 1.当代码块 加上 synchrozized之后,代码会发生什么改变? 答案:有两条改变。一个是原子性(atomicity),一个是可见性(visibility)。原子性意味着一次只能有一个线程获得代码锁,进入synchronized 包围的代码块中执行。而可见性则是对不同范围内对变量的修改做出的一致性。强调变量的可见性与一致性,是因为在Java 内存中,内存缓存和编译器优化在多线程条件下会造成各种反常行为。一般来说,线程以某种不必让其他线程立即可以看到的方式(不管这些线程在寄存器(register)中、在处理器特定的缓存(CPU cache)中,还是通过指令重排或者其他编译器优化),不受缓存变量值的约束,但是加人synchronized关键字之后,那么运行库将确保某一线程对变量所做的更新先于对现有 synchronized 块所进行的更新,当进入由同一监控器(lock)保护的另一个 synchronized 块时,将立刻可以看到这些对变量所做的更新。类似的规则也存在于 volatile 变量 2. 为什么需要java.util.concurrent.lock? 主要是synchronized是比较古老的实现机制,设计较早,有一些功能上的限制: —— 它无法中断一个正在等候获得锁的线程 ——也无法通过投票得到锁,如果不想等下去,也就没法得到锁。 ——同步还要求锁的释放只能在与获得锁所在的堆栈帧相同的堆栈帧中进行 3. 重入锁 ReentrantLock java.util.concurrent.lock 中的 Lock 框架是锁定的一个抽象,它允许把锁定的实现作为 Java 类,而不是作为语言的特性来实现。 这就为 Lock 的多种实现留下了空间,各种实现可能有不同的调度算法、性能特性或者锁定语义。 ReentrantLock 类实现了Lock ,它拥有与 synchronized 相同的并发性和内存语义,但是添加了类似锁投票、定时锁等候和可中断锁等候的一些特性。 此外,它还提供了在激烈争用情况下更佳的性能。(换句话说,当许多线程都想访问共享资源时,JVM 可以花更少的时候来调度线程,把更多时间用在执行线程上。) reentrant 锁意味着什么呢?简单来说,它有一个与锁相关的获取计数器,如果拥有锁的某个线程再次得到锁,那么获取计数器就加1,然后锁需要被释放两次才能获得真正释放。这模仿了 synchronized 的语义;如果线程进入由线程已经拥有的监控器保护的 synchronized 块,就允许线程继续进行,当线程退出第二个(或者后续) synchronized 块的时候,不释放锁,只有线程退出它进入的监控器保护的第一个 synchronized 块时,才释放锁。 - Lock lock = new ReentrantLock();
- lock.lock();
- try {
- // update object state
- }
- finally {
- lock.unlock();
- }
复制代码 上面的代码可以看出, Lock 和 synchronized 有一点明显的区别 —— lock 必须在 finally 块中释放。否则,如果受保护的代码将抛出异常,锁就有可能永远得不到释放!这一点区别看起来可能没什么,但是实际上,它极为重要。忘记在 finally 块中释放锁,可能会在程序中留下一个定时炸弹,当有一天炸弹爆炸时,您要花费很大力气才有找到源头在哪。而使用同步,JVM 将确保锁会获得自动释放。
- package com.mahoutchina.java.concurrent.lock;
-
- import java.util.concurrent.ExecutorService;
- import java.util.concurrent.Executors;
- import java.util.concurrent.TimeUnit;
- import java.util.concurrent.locks.Condition;
- import java.util.concurrent.locks.ReentrantLock;
-
- public class LockSample {
-
- /**
- * @param args
- */
- public static void main(String[] args) {
- final ExecutorService exec = Executors.newFixedThreadPool(4);
- final ReentrantLock lock = new ReentrantLock();
- final Condition con = lock.newCondition();
- final int time = 5;
- final Runnable add = new Runnable() {
-
- @Override
- public void run() {
- System.out.println("Pre" + lock.toString());
- lock.lock();
-
- try {
- con.await(time, TimeUnit.SECONDS);
- } catch (InterruptedException e) {
- e.printStackTrace();
- } finally {
- System.out.println("Post " + lock.toString());
- lock.unlock();
- }
-
- }
- };
-
- for (int i = 0; i < 4; i++) {
- exec.submit(add);
- }
- exec.shutdown();
-
- }
-
- }
复制代码
|