并发编程-notify和wait

通过wait和notify来实现发布订阅。就是线程1（生产者）生产一个数字，线程2（消费者）消费一个数字。消费的速度决定于生产者的速度。
主对象 Mymain.java

package tv.lab.thread;

public class Mymain {
    public static void main(String[] args) {
        Ticket ticket = new Ticket();
        //创建2个任务，分别是r01和r02，并分别用2个线程运行这2个任务。注意，这里是2个线程，每个线程上有一个独立的任务。线程共享的对象是ticket
        Runnable01 r01 = new Runnable01(ticket);  
        Runnable02 r02 = new Runnable02(ticket);
        Thread t1 = new Thread(r01, "t1");  //声明线程t1
        Thread t2 = new Thread(r02, "t2");  //声明线程t2

        t1.start();
        t2.start();
    }
}

共享对象Ticket.java

package tv.lab.thread;

public class Ticket {
    int num = 0;
    boolean hasTicket = false;
}

生产对象Runnable01.java，这个是要生产数字的，产出的数字供消费者任务Runnable02.java消费

package tv.lab.thread;

import java.util.concurrent.TimeUnit;

public class Runnable01 implements Runnable {

    Ticket ticket;

    public Runnable01(Ticket ticket) {
        this.ticket = ticket;  //将共享对象通过构造函数传递过来
    }

    @Override
    public void run() {
        while (true) {
            try {
                TimeUnit.MILLISECONDS.sleep(10);  //休眠10毫秒
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            synchronized (Ticket.class) { 
                if (ticket.hasTicket == true) {
                    try {
                        Ticket.class.wait();  //如果为true，就是有票情况下，就等待，直到票被消费掉后，再产生新的票，如果不被消费，就一直挂起。
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                } else {
                    System.out.println(Thread.currentThread().getName() + " " + ++ticket.num);
                    ticket.hasTicket = true;
                    Ticket.class.notify();  //将等待的线程激活
                }
            }
        }
    }
}

对上面代码的说明

• 将Runnable01.java中的Ticket.class 替换为 ticket对象可以不可以？当然可以，只有是线程公用的对象即可，无论是Ticket.class或ticket，都是线程之间公用的对象。只有公用的对象，才可以用作锁。
  思考：将Ticket.class换为new Ticket()可以吗？肯定不可以，因为2个线程有2个不同的线程任务（Runnable01.java Runnable02.java），如果用new Ticket()就创建了2个不同的对象，不同对象是不能用在synchronized()同步锁中的，同步锁必须是线程之间公用的对象。
• 如果将synchronized (Ticket.class) 这个同步代码块去掉可以吗？不可以，wait()和notify()必须在synochronized()同步代码块儿内才行。 意思就是说wait和notify是在获取对象锁的情况下才能使用，没有获取对象锁的情况下，是不能使用wait和notify的。

消费任务Runnable02.java，当生产者生产后，这个任务用来消费任务

package tv.lab.thread;

public class Runnable02 implements Runnable {

    Ticket ticket;

    public Runnable02(Ticket ticket) {
        this.ticket = ticket;
    }

    @Override
    public void run() {
        while (true) {

            synchronized (Ticket.class) {
                if (ticket.hasTicket == false) {
                    try {
                        Ticket.class.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                } else {  //如果有票，就打印出来
                    System.out.println("   " + Thread.currentThread().getName() + " " + ticket.num);
                    ticket.hasTicket = false;
                    Ticket.class.notify();
                }
            }
        }
    }
}

执行结果如下：
生产和消费成对出现。当生产一个数字后，就等待（wait）消费任务来消费，并通知消费任务来消费。当消费任务消费后，就挂起，通知生产任务生产。

1580369096121.jpg