用BlockingQueue实现生产者消费者问题

比眉伴天荒 2022-02-04 10:47 170阅读 0赞

import java.util.concurrent.ArrayBlockingQueue;
    import java.util.concurrent.BlockingDeque;
    import java.util.concurrent.BlockingQueue;
    
    public class ProcuceConsumer {
        private static BlockingQueue<Object> queue=new ArrayBlockingQueue<>(5);
        private static class Produce extends Thread{
            @Override
            public void run(){
                try{
                    queue.put("1");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("produce");
    
            }
    
        }
        private static class Consumer extends Thread{
            @Override
            public void run(){
                try {
                    queue.take();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Consumer");
            }
        }
        public static void main(String[] args){
            for(int i=0;i<2;i++){
                Produce p=new Produce();
                p.start();
            }
            for(int i=0;i<5;i++){
                Consumer c=new Consumer();
                c.start();
            }
            for(int i=0;i<4;i++){
                Produce p=new Produce();
                p.start();
            }
        }
    
    }

运行结果如下![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21hdHJpeFpDTA_size_16_color_FFFFFF_t_70][]

队列的容量设置为5，队列空时take()阻塞，满时put()阻塞

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21hdHJpeFpDTA_size_16_color_FFFFFF_t_70]: /images/20220204/6dfa9347c30c49498769ce126cd3c480.png