java 生产者和消费者demo

package com.benq;

import java.util.*;
import java.util.concurrent.TimeUnit;

public class HH {
    public static void main(String[] args){

        var store=new MyStore<Integer>(20);

        for(int i=0;i<10;i++){
            var producer=new Procuder<Integer>(store);
            producer.set(i);
            var t=new Thread(producer);
            t.setDaemon(true);
            t.start();

            var consumer=new Consumer<Integer>(store);
            var t1=new Thread(consumer);
            t1.setDaemon(true);
            t1.start();
        }

        try {
            TimeUnit.SECONDS.sleep(10);
        }catch (InterruptedException ie){
            ie.printStackTrace();
        }
    }
}

interface IStore<T>{
    void produce(T t);
    void consume();
}
//仓库
class MyStore<T> implements IStore<T>{
    //存储物品
    private LinkedList<T> list;
    //当前物品数量
    private volatile int num;
    //仓库最大存储数量
    private int MAX_NUM;

    public MyStore(int maxNum) {
        this.list =new LinkedList<T>();
        this.MAX_NUM = maxNum>0?maxNum:100;
    }

    @Override
    public void produce(T t) {

        synchronized (list){
            if (num+1>this.MAX_NUM){
                try {
                    list.wait();
                }catch (InterruptedException ie){
                    ie.printStackTrace();
                }
            }
            list.add(t);
            System.out.println(Thread.currentThread().getName()+" produce "+t.toString());
            num++;
            System.out.println("the store count is "+ String.valueOf(num));
            list.notifyAll();
        }
    }

    @Override
    public void consume() {
        synchronized (list){
            if (this.num==0){
                try {
                    list.wait();
                }catch (InterruptedException ie){
                    ie.printStackTrace();
                }
            }
            T t= list.remove();
            System.out.println(Thread.currentThread().getName()+" consume "+t.toString());
            num--;
            System.out.println("the store count is "+ String.valueOf(num));
            list.notifyAll();
        }
    }
}

class Procuder<T> implements Runnable{

    private MyStore<T> store;
    private T t;

    public Procuder(MyStore<T> store) {
        this.store = store;
    }


    public void set(T t) {
        this.t=t;
    }


    @Override
    public void run() {
        if (this.store!=null){
            store.produce(this.t);

        }
    }
}

class Consumer<T> implements Runnable{

    private MyStore<T> store;

    public Consumer(MyStore<T> store) {
        this.store = store;
    }

    @Override
    public void run() {
        if (this.store!=null){
            store.consume();
        }
    }
}