/**
 * @Author Dominick Li
 * @CreateTime 2022/3/6 20:03
 * @Description 消息生產(chǎn)者
 **/
public class Product implements Runnable {
    private BlockingQueue<String> bq;
    /**
     * 多少秒生產(chǎn)一條任務(wù)
     */
    private int period;
    private Random r = new Random();
    /**
     * 生產(chǎn)者名稱
     */
    private String name;
    Product(BlockingQueue<String> bq, int period, String name) {
        this.bq = bq;
        this.period=period;
        this.name=name;
    }
    @Override
    public void run() {
        try {
            while (true){
                Thread.sleep(period);
                String product=String.valueOf(r.nextInt(100));
                //如果隊(duì)列滿了則阻塞
                bq.put(product);
                System.out.println("生產(chǎn)者["+this.name+"]生產(chǎn)"+product+"，當(dāng)前隊(duì)列中產(chǎn)品為:"+bq);
            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}
/**
 * @Author Dominick Li
 * @CreateTime 2022/3/6 20:11
 * @Description 消費(fèi)者
 **/
public class Cusumer implements Runnable {
    private BlockingQueue<String> bq;
    /**
     * 多少秒獲取一條任務(wù)
     */
    private int period;
    /**
     * 消費(fèi)者名稱
     */
    private String name;
    Cusumer(BlockingQueue<String> bq, int period, String name) {
        this.bq = bq;
        this.period=period;
        this.name=name;
    }
    @Override
    public void run() {
        try {
            while (true){
                Thread.sleep(period);
                String value=bq.take();
                System.out.println("消費(fèi)者["+this.name+"]消費(fèi)"+value+"，當(dāng)前隊(duì)列中產(chǎn)品為:"+bq);
            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}
public class Test {
    public static void main(String[] args) {
        BlockingQueue blockingQueue = new ArrayBlockingQueue(5);
        ExecutorService pool = Executors.newCachedThreadPool();
        pool.execute(new Product(blockingQueue, 1000, "生產(chǎn)者"));
        pool.execute(new Cusumer(blockingQueue, 5000, "消費(fèi)者001"));
        pool.execute(new Cusumer(blockingQueue, 5000, "消費(fèi)者002"));
        pool.shutdown();
    }
}

public class Test {
    public static void main(String[] args) {
        LinkedBlockingQueue linkedBlockingQueue = new LinkedBlockingQueue(5);
        ExecutorService pool = Executors.newCachedThreadPool();
        pool.execute(new Product(linkedBlockingQueue, 1000, "生產(chǎn)者"));
        pool.execute(new Cusumer(linkedBlockingQueue, 5000, "消費(fèi)者1"));
        pool.shutdown();
    }
}

public class PriorityProduct implements Comparable<PriorityProduct> {
    /**
     * 任務(wù)的優(yōu)先級(jí)
     */
    private int priority;
    private String productName;
    public PriorityProduct(int priority, String productName) {
        this.priority = priority;
        this.productName = productName;
    }
    @Override
    public int compareTo(PriorityProduct o) {
        if (o == null) return -1;
        if (o == this) return 0;
        return o.priority - this.priority;
    }
    @Override
    public String toString(){
        return "{priority="+priority+",name="+this.productName;
    }
}
public class PriorityBlockQueueProduct implements Runnable {
    private PriorityBlockingQueue<PriorityProduct> bq;
    /**
     * 多少秒生產(chǎn)一條任務(wù)
     */
    private int period;
    private Random r = new Random();
    public PriorityBlockQueueProduct(PriorityBlockingQueue<PriorityProduct> bq, int period) {
        this.bq = bq;
        this.period = period;
    }
    @Override
    public void run() {
        try {
            while (true) {
                Thread.sleep(period);
                if(bq.size()>10){
                    //限制大小
                    continue;
                }
                  //隨機(jī)生成優(yōu)先級(jí)5以內(nèi)的
                PriorityProduct priorityProduct = new PriorityProduct(r.nextInt(5), "test");
                //如果隊(duì)列滿了則阻塞
                bq.put(priorityProduct);
                //System.out.println("生產(chǎn)者商品[" +priorityProduct + "]，當(dāng)前隊(duì)列中產(chǎn)品為:" + bq);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
public class PriorityBlockQueueCusumer implements Runnable {
    private PriorityBlockingQueue<PriorityProduct> bq;
    /**
     * 多少秒消費(fèi)一條任務(wù)
     */
    private int period;
    public PriorityBlockQueueCusumer(PriorityBlockingQueue<PriorityProduct> bq, int period) {
        this.bq = bq;
        this.period = period;
    }
    @Override
    public void run() {
        try {
            while (true) {
                Thread.sleep(period);
                //如果隊(duì)列滿了則阻塞
                PriorityProduct priorityProduct=bq.take();
                System.out.println("消費(fèi)產(chǎn)品[" +priorityProduct + "]，當(dāng)前隊(duì)列中產(chǎn)品為:" + bq);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
public class PriorityTest {
    public static void main(String[] args) {
        PriorityBlockingQueue<PriorityProduct> priorityProducts=new PriorityBlockingQueue<>();
        ExecutorService executorService= Executors.newFixedThreadPool(2);
        executorService.execute(new PriorityBlockQueueProduct(priorityProducts,100));
        executorService.execute(new PriorityBlockQueueCusumer(priorityProducts,1000));
    }
}