java多线程（二）锁对象 - HelloWorld开发者社区

转载请注明出处：http://blog.csdn.net/xingjiarong/article/details/47679007
在上一篇博客中，我们讨论了Race Condition现象以及它产生的原因，现在我们知道它是不好的一种现象了，那么我们有什么方法避免它呢。最直接有效的方式就是放弃多线程，直接改为使用单线程但操作数据，但是这是不优雅的，因为我们知道有时候，多线程有它自己的优势。在这里我们讨论两种其他的方法——锁对象和条件对象。

锁对象

java SE5.0之后为实现多线程的互斥引入了ReentrantLock类。ReentrantLock类一个可重入的互斥锁 Lock，它具有与使用 synchronized 方法和语句所访问的隐式监视器锁相同的一些基本行为和语义，但功能更强大。

ReentrantLock类有两种构造方法：

构造方法

一、不带公平参数的构造方法

private ReentrantLock lock = new ReentrantLock();

默认的是非公平锁，这种锁不会根据线程等待时间的长短来优先调度线程。

这样就构造了一个锁对象lock。

二、带公平参数的锁对象

private ReentrantLock lock = new ReentrantLock(true);

此类的构造方法接受一个可选的公平参数。当设置为 true 时，在多个线程的争用下，这些锁倾向于将访问权授予等待时间最长的线程。否则此锁将无法保证任何特定访问顺序。

公平锁和非公平锁的区别：

与采用默认设置（使用不公平锁）相比，使用公平锁的程序在许多线程访问时表现为很低的总体吞吐量（即速度很慢，常常极其慢），但是在获得锁和保证锁分配的均衡性时差异较小。不过要注意的是，公平锁不能保证线程调度的公平性。因此，使用公平锁的众多线程中的一员可能获得多倍的成功机会，这种情况发生在其他活动线程没有被处理并且目前并未持有锁时。

使用方法

class X {
    private final ReentrantLock lock = new ReentrantLock();

    // 其他变量的定义

    public void m() { 
     lock.lock();  // 当试图获得锁时，如果锁已经被别的线程占有，那么该线程会一直被阻塞，直到获得锁
     try {
       // 处理数据
     } finally {
       lock.unlock(); //释放锁
     }
   }
}

首先为大家介绍一下，ReentrantLock类的两个最常用的方法：

lock()
获得锁对象，如果该锁对象没有被其他线程占有，那么可以立刻获得锁，并执行接下来的处理；如果锁对象已经被其他对象占有，那么该线程就会被阻塞在请求锁的对象的操作上，直到其他的线程释放锁，该线程得到锁，才能继续的向下执行。

unlock()
释放锁，已经获得锁对象的线程在操作完数据后要释放锁，以便其他的线程重新获得锁来执行自己的操作，否则所有的试图获得锁的线程都不能继续向下执行。

使用方法简单明了，就是在执行各个线程都要操作相同数据的代码之前请求锁，在finally语句中释放锁，为什么要在finally中释放锁呢，这是因为如果try语句块中有语句发生异常，则会直接跳过try中所有的剩余代码包括unlock（），所以锁对象就不能得到释放，其他的线程也不能继续向下执行，导致程序不能继续执行，我们在finally中释放锁，这样就能保证一定可以将锁释放掉，不管获得锁的线程是不是正确的执行结束。

现在来使用这个方法修改一下我们上一篇博客中的代码：

import java.util.concurrent.locks.ReentrantLock;

class MyThread implements Runnable {
    /**
     * 计算类型，1表示减法，其他的表示加法
     */
    private int type;
    /**
     * 锁对象
     */
    private static ReentrantLock lock = new ReentrantLock();

    public MyThread(int type) {
        this.type = type;
    }

    public void run() {

        if (type == 1)
            for (int i = 0; i < 10000; i++) {

                lock.lock();

                Test.num--;

                lock.unlock();

            }
        else
            for (int i = 0; i < 10000; i++) {

                lock.lock();

                Test.num++;

                lock.unlock();
            }

    }
}

public class Test {

    public static int num = 1000000;

    public static void main(String[] args) {

        Thread a = new Thread(new MyThread(1));
        Thread b = new Thread(new MyThread(2));

        a.start();
        b.start();

        /*
         * 主线程等待子线程完成，然后再打印数值
         */
        try {
            a.join();
            b.join();
        } catch (Exception e) {
            e.printStackTrace();
        }

        System.out.println(num);
    }

}

再多运行几次，是不是结果都是正确的呢。

现在，我们来解释一下，什么是可重入的锁。ReentrantLock类中有一个计数器，用来表示一个线程获取锁的数量，初始值为0，当一个线程获得锁时，该值被置为1，可重入的意思就是，已经获得锁的线程还可以继续调用同一个锁所保护的方法，也就是再一次获得锁，当再一次获得锁时，ReentrantLock中的计数器就加1，每释放一次锁，计数器就减1，当计数器减为0的时候，这个线程才是真正的释放了这个锁。

我们接着讨论另外一个非常重要的问题。ReentrantLock类是依赖于创建它的类的对象。什么意思呢，就是说如果两个线程同时访问同一个ReentrantLock对象的lock（）方法保护的方法时，OK，这是没有问题的，锁对象会成功的保护数据操作不会出错。但是如果两个线程同时访问ReentrantLock类的不同对象的被lock（）保护的方法，那么这两个线程是不会相互影响的，也就是说lock（）方法这时不能保证数据的正确性。

我们来看一下上边那个代码的这一部分：

Thread a = new Thread(new MyThread(1));
Thread b = new Thread(new MyThread(2));

这里建立了两个对象a和b，所以他们每个类都有自己的ReentrantLock对象，这就是我们上边所说的ReentrantLock类的不同对象，这样如果两个线程分别操作a和b的数据，lock方法是不会有效的。

不信我们试试看这个代码：

import java.util.concurrent.locks.ReentrantLock;

class MyThread implements Runnable {
    /**
     * 计算类型，1表示减法，其他的表示加法
     */
    private int type;
    /**
     * 锁对象
     */
    private ReentrantLock lock = new ReentrantLock();

    public MyThread(int type) {
        this.type = type;
    }

    public void run() {

        if (type == 1)
            for (int i = 0; i < 10000; i++) {

                lock.lock();

                Test.num--;

                lock.unlock();

            }
        else
            for (int i = 0; i < 10000; i++) {

                lock.lock();

                Test.num++;

                lock.unlock();
            }

    }
}

public class Test {

    public static int num = 1000000;

    public static void main(String[] args) {

        Thread a = new Thread(new MyThread(1));
        Thread b = new Thread(new MyThread(2));

        a.start();
        b.start();

        /*
         * 主线程等待子线程完成，然后再打印数值
         */
        try {
            a.join();
            b.join();
        } catch (Exception e) {
            e.printStackTrace();
        }

        System.out.println(num);
    }

}