Java基础语法测试-基础数据类型-注解-数组-inet-反射-oop-Java代码实现

package com.hzs.basic.multithread; /** * @author Cherist Huan * @version 1.0 * @date 2021/6/23 9:42 * @note 测试管程法 */ public class TestPC { public static void main(String[] args) { SynContainer synContainer = new SynContainer(); new Product(synContainer).start(); new Consumer(synContainer).start(); } } // 产品类 class Chicken{ private int id; public Chicken(int id) { this.id = id; } public int getId() { return id; } public void setId(int id) { this.id = id; } } //生产者 class Product extends Thread{ SynContainer synContainer ; public Product(SynContainer synContainer){ this.synContainer = synContainer; } @Override public void run() { for (int i = 0; i < 100; i++) { System.out.println("生产了第"+i+"个"); synContainer.push(new Chicken(i)); } } } // 消费者 class Consumer extends Thread{ SynContainer synContainer ; public Consumer(SynContainer synContainer){ this.synContainer = synContainer; } @Override public void run() { for (int i = 0; i < 100; i++) { System.out.println("消费了第"+synContainer.pop().getId()+"个"); } } } //缓冲区，容器类 class SynContainer{ // 新建一个存储数组 Chicken[] chickens = new Chicken[10]; private int count = 0; // 计数器，容器中还有多少只产品 // 生产 public synchronized void push(Chicken chicken){ // 首先，判断容器有没有满，如果满了，通知消费者消费,本身进入wait if(count == chickens.length){ try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } // 否则，进行生产 chickens[count] = chicken; count++; // 通知其他线程消费 this.notifyAll(); } // 消费者消费 public synchronized Chicken pop(){ // 首先，判断容器有没有产品,如果没有了，通知生产者进行生产,本对象进入wait if(count <= 0) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } // 如果有，进行消费 count--; Chicken chicken = chickens[count]; // 通知其他线程进行生产 this.notifyAll(); return chicken; } }