Java实现消费者生产者

忘是亡心i 2021-09-25 15:00 369阅读 0赞

import java.util.LinkedList;
    
    /** * @auther: 巨未 * @DATE: 2021/9/7 0007 23:45 * @Description: 仓库 */
    public class Storage { 
    
        // 仓库容量
        private final int MAX_SIZE = 10;
        // 仓库存储的载体
        private LinkedList<Object> list = new LinkedList<>();
    
        public void produce() { 
            synchronized (list) { 
                while (list.size() + 1 > MAX_SIZE) { 
                    System.out.println("【生产者" + Thread.currentThread().getName()
                            + "】仓库已满");
                    try { 
                        list.wait();
                    } catch (InterruptedException e) { 
                        e.printStackTrace();
                    }
                }
                list.add(new Object());
                System.out.println("【生产者" + Thread.currentThread().getName()
                        + "】生产一个产品，现库存" + list.size());
                list.notifyAll();
            }
        }
    
        public void consume() { 
            synchronized (list) { 
                while (list.size() == 0) { 
                    System.out.println("【消费者" + Thread.currentThread().getName()
                            + "】仓库为空");
                    try { 
                        list.wait();
                    } catch (InterruptedException e) { 
                        e.printStackTrace();
                    }
                }
                list.remove();
                System.out.println("【消费者" + Thread.currentThread().getName()
                        + "】消费一个产品，现库存" + list.size());
                list.notifyAll();
            }
        }
    
    
        public static void main(String[] args) { 
            Storage storage = new Storage();
            Thread p1 = new Thread(new Producer(storage));
            Thread p2 = new Thread(new Producer(storage));
            Thread p3 = new Thread(new Producer(storage));
    
            Thread c1 = new Thread(new Consumer(storage));
            Thread c2 = new Thread(new Consumer(storage));
            Thread c3 = new Thread(new Consumer(storage));
    
            p1.start();
            p2.start();
            p3.start();
            c1.start();
            c2.start();
            c3.start();
        }
    }

生产者

public class Producer implements Runnable{ 
        private Storage storage;
    
        public Producer(Storage storage){ 
            this.storage = storage;
        }
    
        @Override
        public void run(){ 
            while(true){ 
                try{ 
                    Thread.sleep(1000);
                    storage.produce();
                }catch (InterruptedException e){ 
                    e.printStackTrace();
                }
            }
        }
    }

消费者

public class Consumer implements Runnable{ 
        private Storage storage;
    
        public Consumer(Storage storage){ 
            this.storage = storage;
        }
    
        @Override
        public void run(){ 
            while(true){ 
                try{ 
                    Thread.sleep(3000);
                    storage.consume();
                }catch (InterruptedException e){ 
                    e.printStackTrace();
                }
            }
        }
    }