【Java】线程通信

package priv.kuki.thread;

/**
 * @author Tang-J-L
 * 生产者&消费者
 * 生产者（Producer）将产品交给店员（Clerk），而消费者（Customer）从店员处取走产品，店员一次只能持有固定数量的产品（比如：20），
 * 如果生产者试图生产更多的产品，店员会叫生产者停一下；如果店中还有空位放产品了再通知生产者继续生产，如果店中没有产品了，店员会告诉消费者等一下，
 * 如果店中有产品了再通知消费者来取走产品。
 *
 * 分析：
 *  1.两个线程：生产者、消费者
 *  2.共享数据：产品数量
 *  3.线程之间存在通信
 *  4.存在线程安全问题，需要解决（因为有共享数据）
 *
 *  TODO:
 *      1.创建Clear、Producer、Customer三个类
 *      2.产品数量由店员维护（提供增加，减少产品数量的方法）
 *      3.
 *
 * @Date 2023/2/28 周二 14:59
 */

class Clerk{

    /**
     * 维护商品数量
     */
    private int productNum = 0;

    /**
     * 商品最大数量，避免魔法值
     */
    private static final int MAX_NUMBER = 20;

    /**
     * 商品最低数量，避免魔法值
     */
    private static final int MIN_NUMBER = 0;

    /**
     * 商品增加
     */
    public synchronized void increase(){

        if (productNum >= MAX_NUMBER) {

            try{
                // 等待
                wait();
            } catch(InterruptedException e){
                e.printStackTrace();
            }

        }else {

            productNum++;
            System.out.println(Thread.currentThread().getName()+"生产了第"+productNum+"个商品");

            // 唤醒消费者
            this.notifyAll();
        }
    }

    /**
     * 商品数量减少
     */
    public synchronized void reduce(){

        if (productNum <= MIN_NUMBER) {

            try{
                // 等待
                wait();
            } catch(InterruptedException e){
                e.printStackTrace();
            }

        }else {

            System.out.println(Thread.currentThread().getName()+"消费了第"+productNum+"个商品");
            productNum--;

            // 唤醒生产者
            this.notifyAll();
        }
    }
}

/**
 * 生产者
 */
class Producer extends Thread{

    private Clerk clerk;

    Producer(Clerk clerk){
        this.clerk = clerk;
    }

    @Override
    public void run(){

        while(true){

            System.out.println("生产者开始生产商品...");

            try{
                Thread.sleep(50);
            } catch(InterruptedException e){
                throw new RuntimeException(e);
            }

            clerk.increase();

        }
    }
}

/**
 * 消费者
 */
class Customer extends Thread{

    private Clerk clerk;

    Customer(Clerk clerk){
        this.clerk = clerk;
    }

    @Override
    public synchronized void run(){

        while(true){
            System.out.println("消费者开始消费商品...");

            try{
                Thread.sleep(1000);
            } catch(InterruptedException e){
                throw new RuntimeException(e);
            }

            clerk.reduce();
        }

    }
}

/**
 * 测试类
 * @author Tang-J-L
 */
public class ProducerAndCustomerTest{

    public static void main(String[] args){

		// 共享数据，通过同一个数据创建线程，实现数据共享
        Clerk clerk = new Clerk();

        Producer producer = new Producer(clerk);
        Customer customer1 = new Customer(clerk);
        Customer customer2 = new Customer(clerk);

        producer.setName("生产者");
        customer1.setName("消费者1");
        customer2.setName("消费者2");

        producer.start();
        customer1.start();
        customer2.start();

    }

}