java多线程实现生产者消费者场景

小鱼儿 2022-05-28 03:08 174阅读 0赞

## 商店 ##

public class Tmall {
    
        private int count;
    
        public final int MAX_COUNT = 10;
    
        public synchronized void push () {
            while(count >= MAX_COUNT) {
                try {
                    System.out.println(Thread.currentThread().getName() + " 库存数量达到上限，生产者停止生产。");
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            count ++;
            System.out.println(Thread.currentThread().getName() + " 生产者生产，当前库存为：" + count);
            notifyAll();
        }
    
        public synchronized void take () {
    
            while(count <= 0) {
                try {
                    System.out.println(Thread.currentThread().getName() + " 库存数量为零，消费者等待。");
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            count --;
            System.out.println(Thread.currentThread().getName() + " 消费者消费，当前库存为：" + count);
            notifyAll();
        }
    
    }

## 生产者 ##

public class PushTarget implements Runnable { 
    
        private Tmall tmall;
    
        public PushTarget(Tmall tmall) {
            this.tmall = tmall;
        }
    
        @Override
        public void run() {
            while(true) {
                tmall.push();
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    
    }

## 消费者 ##

public class TakeTarget implements Runnable { 
    
        private Tmall tmall;
    
        public TakeTarget(Tmall tmall) {
            this.tmall = tmall;
        }
    
        @Override
        public void run() {
            while(true) {
                tmall.take();
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    
    }

## 运行： ##

public class Main {
    
        public static void main(String[] args) {
    
            Tmall tmall = new Tmall();
    
            PushTarget p = new PushTarget(tmall);
            TakeTarget t = new TakeTarget(tmall);
    
            new Thread(p).start();
            new Thread(p).start();
            new Thread(p).start();
            new Thread(p).start();
            new Thread(p).start();
    
            new Thread(t).start();
            new Thread(t).start();
            new Thread(t).start();
            new Thread(t).start();
            new Thread(t).start();
    
        }
    
    }

![这里写图片描述][70]

[70]: /images/20220528/f8122be2c975465f8ab1820b6d649969.png