利用线程模拟一个简单的商品生产和消费

悠悠 2022-11-09 14:10 62阅读 0赞

首先是商品类，里面有商品生产和扣库存的方法：

package com.chen.test.demo3;
    
    /**
     * @Description:
     * @Author chenjianwen
     * @Date 2021/3/15
     **/
    public class Product {
    
        private static volatile int p = 1; //假设这里只有一个并保持一个有效商品
    
        /**
         * 生产商品
         * @throws InterruptedException
         */
        public synchronized void produce() throws InterruptedException {
            if(p == 1){
                wait();
            }
            p += 1;
            System.out.println("produce = " + p);
            notify();
        }
    
        /**
         * 消费商品
         * @throws InterruptedException
         */
        public synchronized void consume() throws InterruptedException {
            if(p == 0){
                wait();
            }
            p -= 1;
            System.err.println("consume = " + p);
            notify();
        }
    }

然后是生产者线程和消费者线程

package com.chen.test.demo3;
    
    import lombok.SneakyThrows;
    
    /**
     * @Description:生产者线程
     * @Author chenjianwen
     * @Date 2021/3/15
     **/
    public class ProduceThread extends Thread{
    
        private Product p;
    
        public ProduceThread(Product p){
            this.p = p;
        }
    
        @SneakyThrows
        @Override
        public void run() {
            while (true){
                p.produce();
            }
        }
    }

package com.chen.test.demo3;
    
    import lombok.SneakyThrows;
    
    /**
     * @Description:消费者线程
     * @Author chenjianwen
     * @Date 2021/3/15
     **/
    public class ConsumerThread extends Thread {
    
        private Product p;
    
        public ConsumerThread(Product p){
            this.p = p;
        }
    
        @SneakyThrows
        @Override
        public void run() {
            while(true){
                p.consume();
            }
        }
    }

启动类

package com.chen.test.demo3;
    
    
    /**
     * @Description:
     * @Author chenjianwen
     * @Date 2021/3/15
     **/
    public class ThreadTest {
    
        public static void main(String[] args) {
            Product p = new Product();
            new ProduceThread(p).start();
            new ConsumerThread(p).start();
        }
    }