【并发编程篇】阻塞队列BlockingQueue

忘是亡心i 2024-04-17 06:40 84阅读 0赞

#### 文章目录 ####

*  ?简述阻塞队列BlockingQueue
 *  ?4种API
 *   *  ⭐抛出异常
     *   *  ?队列已满
         *  ?队列已空
         *  ?️?检测队首元素
     *  ⭐有返回值，没有异常
     *   *  ?️?检测队首元素
     *  ⭐阻塞，一直等待
     *  ⭐超时等待

![在这里插入图片描述][94b81ef62b0d451b94e31f75d416af2b.png_pic_center]

## ?简述阻塞队列BlockingQueue ##

阻塞队列是一种特殊的队列，它具有线程安全的特性，并且在队列满或者空的情况下具有阻塞线程的能力。当队列为空时，试图从队列中获取元素的线程将被阻塞，直到队列中有可用元素；当队列已满时，试图向队列中添加元素的线程将被阻塞，直到队列中有空闲位置。

阻塞队列常用于生产者-消费者模式的多线程编程中，它可以很好地协调不同线程之间的数据共享和通信。Java 中的 java.util.concurrent 包提供了多种类型的阻塞队列实现，如 ArrayBlockingQueue、LinkedBlockingQueue 等，它们在多线程并发编程中发挥重要作用，简化了线程间的协作和数据传递。

## ?4种API ##

![请添加图片描述][0b57500280fb40c3b6200a73468d31a8.jpeg]

### ⭐抛出异常 ###

#### ?队列已满 ####

package org.bq;
    
    import java.util.concurrent.ArrayBlockingQueue;
    
    public class Test {
        
        //抛出异常
        public static void main(String[] args) {
        
            //队列的大小
            ArrayBlockingQueue blockingQueue=new ArrayBlockingQueue<>(3);
    
            System.out.println(blockingQueue.add("a"));
            System.out.println(blockingQueue.add("b"));
            System.out.println(blockingQueue.add("c"));
    
            System.out.println(blockingQueue.add("d"));
        }
    }

![在这里插入图片描述][5e0f1f74c97c4914a35a196940f525cd.png]  
![在这里插入图片描述][7903b3d5c5ed43ddb8b02ddf9517dcb4.png]  
抛出了`队列已满`异常

#### ?队列已空 ####

![在这里插入图片描述][e0e99aaed8884f6caa8fde00e4d13a9c.png]  
![在这里插入图片描述][b71c8f86ed2f46bdb72d5d165bc5773c.png]  
抛出了`队列已空`异常

#### ?️?检测队首元素 ####

![在这里插入图片描述][353c412ec6ca40468cb2e57045ddbd34.png]

### ⭐有返回值，没有异常 ###

![在这里插入图片描述][d894e060daa947e0b7c2e3f7b97b43b3.png]

package org.bq;
    
    import java.util.concurrent.ArrayBlockingQueue;
    
    public class Test1 {
        
        public static void main(String[] args) {
        
            test2();
        }
        public static void test1(){
        
    
        }
        public static void test2(){
        
            //队列的大小
            ArrayBlockingQueue blockingQueue=new ArrayBlockingQueue<>(3);
    
            System.out.println(blockingQueue.offer("a"));
            System.out.println(blockingQueue.offer("b"));
            System.out.println(blockingQueue.offer("c"));
            //System.out.println(blockingQueue.offer("d"));  //false 不抛出异常
    
            System.out.println("===============");
            System.out.println(blockingQueue.poll());
            System.out.println(blockingQueue.poll());
            System.out.println(blockingQueue.poll());
            System.out.println(blockingQueue.poll());  //null 不抛出异常
        }
    }

![在这里插入图片描述][b40427dcb80b47e28a48a0887b0f5a0c.png]

#### ?️?检测队首元素 ####

![在这里插入图片描述][7f35d5c5affb4bf286f57f12b2b0f3bd.png]

### ⭐阻塞，一直等待 ###

package org.Test6;
    
    import java.util.concurrent.ArrayBlockingQueue;
    
    public class Test2 {
        
        public static void main(String[] args) throws InterruptedException {
        
            //队列的大小
            ArrayBlockingQueue blockingQueue=new ArrayBlockingQueue<>(3);
    
            //一直阻塞
            blockingQueue.put("a");
            blockingQueue.put("b");
            blockingQueue.put("c");
    //        blockingQueue.put("d");//阻塞
    
            System.out.println(blockingQueue.take());
            System.out.println(blockingQueue.take());
            System.out.println(blockingQueue.take());
            System.out.println(blockingQueue.take()); //阻塞，会一直等待
        }
    }

![在这里插入图片描述][8097acfc8f89488fb507955073ed8e42.png]

### ⭐超时等待 ###

package org.Test6;
    
    import java.util.concurrent.ArrayBlockingQueue;
    import java.util.concurrent.TimeUnit;
    
    public class Test3 {
        
        public static void main(String[] args) throws InterruptedException {
        
            //队列的大小
            ArrayBlockingQueue blockingQueue=new ArrayBlockingQueue<>(3);
    
            blockingQueue.offer("1");
            blockingQueue.offer("2");
            blockingQueue.offer("3");
    //        blockingQueue.offer("4",2, TimeUnit.SECONDS);  //等待超过2S后退出
    
            blockingQueue.poll();
            blockingQueue.poll();
            blockingQueue.poll();
            blockingQueue.poll(2,TimeUnit.SECONDS); //等待2S后退出
    
        }
    }

![在这里插入图片描述][b83a637808a04828909ecb8fef24ca39.png]

> 在技术的道路上，我们不断探索、不断前行，不断面对挑战、不断突破自我。科技的发展改变着世界，而我们作为技术人员，也在这个过程中书写着自己的篇章。让我们携手并进，共同努力，开创美好的未来！愿我们在科技的征途上不断奋进，创造出更加美好、更加智能的明天！

![在这里插入图片描述][1c89e641ff80435db1b777ce48bc2327.png_pic_center]

[94b81ef62b0d451b94e31f75d416af2b.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/c825baae22034820928256cfed296207.png
[0b57500280fb40c3b6200a73468d31a8.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/e62873ec2e234734a389544e62c2d558.jpeg
[5e0f1f74c97c4914a35a196940f525cd.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/8461793aa72040baa62fb69389a413f4.png
[7903b3d5c5ed43ddb8b02ddf9517dcb4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/d0d1b1b76bbb4177b390044128efb18d.png
[e0e99aaed8884f6caa8fde00e4d13a9c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/b710fd3f09b248d68e52786059915bdb.png
[b71c8f86ed2f46bdb72d5d165bc5773c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/32d028181e10473688f4edd56082d3b3.png
[353c412ec6ca40468cb2e57045ddbd34.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/cc97016560424f12bde255de8c24bbaa.png
[d894e060daa947e0b7c2e3f7b97b43b3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/202fac98fc2e4d509893187ffb10d24b.png
[b40427dcb80b47e28a48a0887b0f5a0c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/da60c10d5b4e405cb7bcbb53f6608c22.png
[7f35d5c5affb4bf286f57f12b2b0f3bd.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/d5356e7cc0e14e55a84b4b57884deac0.png
[8097acfc8f89488fb507955073ed8e42.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/512d8a585fdc496db485dbf409de8cd4.png
[b83a637808a04828909ecb8fef24ca39.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/9bc211b580f34d389b1b199115943981.png
[1c89e641ff80435db1b777ce48bc2327.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/15/be7262b409fa41498873647b1e5bfb85.png