java生产者、消费者—线程安全

客官°小女子只卖身不卖艺 2023-08-17 16:40 41阅读 0赞

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hnZzkyMw_size_16_color_FFFFFF_t_70][]

1、产品

/**
     * 产品
     * Created by hgg on 2019/9/29.
     */
    public class Product {
        private String name;
    
        public Product(String name) {
            this.name = name;
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    }

2、产品池

import java.util.LinkedList;
    import java.util.List;
    
    /**
     * 产品池
     * Created by hgg on 2019/9/29.
     */
    public class ProductPool {
    
        //产品集合，生产者生产，消费者消费
        private List<Product> productList;
    
        private int MAX_SIZE = 0;
    
        public ProductPool(int maxSize){
            this.productList = new LinkedList<Product>();
            this.MAX_SIZE = maxSize;
        }
    
        /**
         * 生产—放入产品池
         * @param product
         */
        public synchronized void push(Product product)  {
            if (productList.size() == MAX_SIZE){
                try {
                    this.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }else {
                productList.add(product);
                this.notifyAll();
            }
        }
    
        /**
         * 每次取出第一个元素
         * @return
         */
        public synchronized Product pop() {
            Product product = null;
            if (this.productList.size() == 0){
                try {
                    this.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            product = productList.remove(0);
            this.notifyAll();
            return product;
        }
    }

3、生产者

/**
     * 生产者
     * Created by hgg on 2019/9/29.
     */
    public class Producter extends Thread {
    
        private ProductPool pool;
    
        public Producter(ProductPool pool) {
            this.pool = pool;
        }
    
        @Override
        public void run() {
            while (true){
                String name = (int)Math.random()*100+"号";
                System.out.println("生产了"+name);
                Product product = new Product(name);
                this.pool.push(product);
            }
        }
    }

4、消费者

/**
     * 消费者
     * Created by hgg on 2019/9/29.
     */
    public class Consumer extends Thread {
        private ProductPool pool;
    
        public Consumer(ProductPool pool) {
            this.pool = pool;
        }
    
        @Override
        public void run() {
            while (true){
                Product product = this.pool.pop();
                System.out.println("消费了："+product.getName());
            }
        }
    }

5、主程序入口

public class MainProgram {
        public static void main(String[] args) {
            ProductPool productPool = new ProductPool(15);
            
            new Producter(productPool).start();
            
            new Consumer(productPool).start();
        }
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hnZzkyMw_size_16_color_FFFFFF_t_70]: /images/20230809/7b7d33b350a741a38618d290f7ab7436.png