Java——线程锁，死锁，等待唤醒机制

一、线程锁

线程安全问题

其实，线程安全问题都是由全局变量及静态变量引起的。若每个线程中对全局变量、静态变量只有读操作，而无写操作，一般来说，这个全局变量是线程安全的；若有多个线程同时执行写操作，一般都需要考虑线程同步，否则的话就可能影响线程安全。

由于线程休眠的特性，从哪休眠就从哪继续执行（一个线程的事情还没干完就被其他线程挤下去了），回来继续干就会导致操作的全局变量或静态变量出现问题。

为了解决这个问题，我们就需要让线程执行完毕（不能被其他线程挤下去），以下是几种解决办法。

1、同步代码块

保证代码块执行完毕，再切换线程。

公式:

synchronized(任意对象){

　　线程要操作的共享数据

}

调用类

public class ThreadDemo {
    public static void main(String[] args) {
        Ticket tk = new Ticket();
        Thread t01 = new Thread(tk);
        Thread t02 = new Thread(tk);
        Thread t03 = new Thread(tk);

        t01.start();
        t02.start();
        t03.start();
    }
}

同步代码块

public class Ticket implements Runnable {
    //定义出售的票源
    private int ticket = 100;

    public void run() {
        while (true) {
            // 因为里面可以填任意对象，所以可以使用this（表示当前实例化的Ticket对象tk）
            synchronized (this) {
                //对票数判断,大于0,可以出售,变量--操作
                if (ticket > 0) {
                    System.out.println(Thread.currentThread().getName() + " 出售第 " + ticket--);
                }
            }
        }
    }
}

同步代码块中的锁对象可以是任意的对象；但多个线程时，要使用同一个锁对象才能够保证线程安全。

2、同步方法

还可以将需要同步的代码块，抽出来一个方法，使用synchronized字段修饰。

public synchronized void method(){

　　可能会产生线程安全问题的代码

}

同步方法

public class Ticket implements Runnable {
    //定义出售的票源
    private int ticket = 100;

    public void run() {
        while (true) {
            func();
        }
    }

    private synchronized void func() {
        //对票数判断,大于0,可以出售,变量--操作
        if (ticket > 0) {
            System.out.println(Thread.currentThread().getName() + " 出售第 " + ticket--);
        }
    }
}

同步方法中的锁对象是this，如果是静态同步方法的话同步锁是本类类名.class

3、Lock接口

public class Ticket implements Runnable{

    //定义出售的票源
    private int ticket = 100;
    //在类的成员位置,创建Lock接口的实现类对象
    private Lock lock = new ReentrantLock();

    public void run(){
        while(true){
            //调用Lock接口方法lock获取锁
            lock.lock();
            //对票数判断,大于0,可以出售,变量--操作
            if( ticket > 0){
                try{
                    //执行可能会引发线程安全问题的代码
                    System.out.println(Thread.currentThread().getName()+" 出售第 "+ticket--);
                }catch(Exception ex){

                }finally{
                    //释放锁,调用Lock接口方法unlock
                    lock.unlock();
                }
            }
        }
    }
}

二、死锁

同步锁使用的弊端：当线程任务中出现了多个同步(多个锁)时，如果同步中嵌套了其他的同步。这时容易引发一种现象：程序出现无限等待，这种现象我们称为死锁。这种情况能避免就避免掉。

三、等待唤醒机制

线程之间的通信：

多个线程在处理同一个资源，但是处理的动作（线程的任务）却不相同。通过一定的手段使各个线程能有效的利用资源。而这种手段即——等待唤醒机制。

等待唤醒机制

等待唤醒机制所涉及到的方法：

其实，所谓唤醒的意思就是让线程池中的线程具备执行资格。必须注意的是，这些方法都是在同步中才有效。同时这些方法在使用时必须标明所属锁，这样才可以明确出这些方法操作的到底是哪个锁上的线程。

仔细查看JavaAPI之后，发现这些方法并不定义在Thread中，也没定义在Runnable接口中，却被定义在了Object类中，为什么这些操作线程的方法定义在Object类中？

因为这些方法在使用时，必须要标明所属的锁，而锁又可以是任意对象。能被任意对象调用的方法一定定义在Object类中。

package cn.x5456.demo;

public class ThreadDemo {
    public static void main(String[] args) {
        Resource r = new Resource();

        // 共享数据
        Input in = new Input(r);
        Output out = new Output(r);

        Thread tin = new Thread(in);
        Thread tout = new Thread(out);

        tin.start();
        tout.start();
    }
}

package cn.x5456.demo;

public class Input implements Runnable{
    private Resource r;
    int i = 0;

    public Input(Resource r){
        this.r=r;
    }


    public void run() {
        while (true){
            synchronized (r){   //要使用同一个对象来看着Input和Output两个同步方法（否则就各自走各自的了）
                if(r.flag){
                    try {
                        r.wait();   //使用同一个对象才能等待+启动
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                if(i%2==0){
                    r.name = "张三";
                    r.sex = "男";
                }else{
                    r.name = "lisi";
                    r.sex = "nv";
                }
                i++;
                r.flag = true;
                r.notify();     //唤醒另一边
            }
        }
    }
}

package cn.x5456.demo;

public class Output implements Runnable{
    private Resource r;

    public Output(Resource r) {
        this.r = r;
    }


    @Override
    public void run() {
        while (true){
            synchronized (r){
                if(!r.flag){
                    try {
                        r.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                System.out.println(r.name+".."+r.sex);
                //标记改成false,唤醒对方线程
                r.flag = false;
                r.notify();
            }
        }
    }
}

package cn.x5456.demo;

public class Resource {
    String name;
    String sex;
    boolean flag = false;
}