Java阻塞队列BlockingQueue基础与使用_F11 - 专业站长和开发者的学习网站

分享到

Java阻塞队列BlockingQueue基础与使用

java 来源：互联网作者：佚名发布时间：2023-01-04 21:29:41 人浏览

摘要

什么是阻塞队列阻塞队列本质上还是一种队列，遵循先进先出，后进后出的原则，在此基础上，如果出队时阻塞队列为空，则会使当前线程陷入阻塞，直到入队新元素时通知线程继续执

什么是阻塞队列

阻塞队列本质上还是一种队列，遵循先进先出，后进后出的原则，在此基础上，如果出队时阻塞队列为空，则会使当前线程陷入阻塞，直到入队新元素时通知线程继续执行，如果入队时阻塞队列为满，则会使当前线程陷入阻塞，直到出队旧元素时才通知线程进行执行。

阻塞队列的特点

BlockingQueue不是新的东西

学会使用队列

阻塞队列四组API

方式	抛出异常	有返回值，不抛出异常	阻塞等待	超时等待
添加	add(E e)	offer(E e)	put()	offer(E e,Time,TimeUnit)
移除	remove()	poll()	take()	poll(Time,TimeUnit)
检测队首元素	element()	peek	无	无

抛出异常是指当队列满时，再次插入会抛出异常（如果队列未满，插入返回值未true）；
返回布尔是指当队列满时，再次插入会返回false；
阻塞是指当队列满时，再次插入会被阻塞，直到队列取出一个元素，才能插入。
超时是指当一个时限过后，才会插入或者取出。

抛出异常

/**

* 抛出异常

public static void test1(){

// 队列的大小

ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);

System.out.println(blockingQueue.add("a"));

System.out.println(blockingQueue.add("b"));

System.out.println(blockingQueue.add("c"));

// IllegalStateException: Queue full 抛出异常！

// System.out.println(blockingQueue.add("d"));

System.out.println(blockingQueue.remove());

// java.util.NoSuchElementException 抛出异常！

// System.out.println(blockingQueue.remove());

}

有返回值，没有异

/**

* 有返回值，没有异常

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(blockingQueue.poll());

System.out.println(blockingQueue.poll()); // null 不抛出异常！

}

等待，阻塞（一直阻塞）

/**

* 等待，阻塞（一直阻塞）

public static void test3() 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())

}

等待，阻塞（等待超时

/**

* 等待，阻塞（等待超时）

public static void test4() throws InterruptedException {

// 队列的大小

ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);

blockingQueue.offer("a");

blockingQueue.offer("b");

blockingQueue.offer("c");

// blockingQueue.offer("d",2,TimeUnit.SECONDS); // 等待超过2秒就退出

System.out.println(blockingQueue.poll());

blockingQueue.poll(2,TimeUnit.SECONDS);

}

SynchronousQueue 同步队列

和其他的BlockingQueue 不一样， SynchronousQueue 不存储元素

put了一个元素，必须从里面先take取出来，否则不能在put进去值！

public class SynchronousQueueDemo {

public static void main(String[] args) {

BlockingQueue<String> blockingQueue = new SynchronousQueue<>(); // 同步队

// new Thread(()->{

try {

System.out.println(Thread.currentThread().getName()+" put 1");

blockingQueue.put("1");

System.out.println(Thread.currentThread().getName()+" put 2");

blockingQueue.put("2");

System.out.println(Thread.currentThread().getName()+" put 3");

blockingQueue.put("3");

} catch (InterruptedException e) {

e.printStackTrace();

}

},"T1").start();

new Thread(()->{

try {

TimeUnit.SECONDS.sleep(3);

System.out.println(Thread.currentThread().getName()+"=>"+blockingQueue.take());

TimeUnit.SECONDS.sleep(3);

System.out.println(Thread.currentThread().getName()+"=>"+blockingQueue.take());

TimeUnit.SECONDS.sleep(3);

System.out.println(Thread.currentThread().getName()+"=>"+blockingQueue.take());

} catch (InterruptedException e) {

e.printStackTrace();

}

},"T2").start();

}

您可能感兴趣的文章 :

原文链接 : https://blog.csdn.net/qq_29917503/article/details/128481367

Tag : Java(337)

MyBatis一级与二级缓存相关配置

1.MyBatis的一级缓存一级缓存是 SqlSession 级别的，通过同一个 SqlSession 查询的数据会被缓存，下次查询相同的数据，就会从缓存中直接获取，
Java阻塞队列BlockingQueue基础与使用

什么是阻塞队列阻塞队列本质上还是一种队列，遵循先进先出，后进后出的原则，在此基础上，如果出队时阻塞队列为空，则会使当前线程
Java实现将每日新闻添加到自己博客中

最近新整了个博客网站，同事在gitee上找的，还不错，gitee上的地址在这里：拾壹博客管理系统。别人的业务，再好也有不满足自己的地方，
Java实现每日给女友微信发送早安信息

据说这个功能最近在抖音上很火，我没有抖音，没有看到。但是我在网上看了，相关案例确实很多，但是大家都是借助于了微信服务号，在
nacos单机本地配置文件存储位置方式

nacos单机本地配置文件存储位置 C:\Users***\nacos\config\config_rpc_client_nacos\ 单机版Nacos文件配置问题 Nacos服务自动关闭在使用Nacos时，有时候会遇
使用lombok的@Data会导致栈溢出StackOverflowError问题

问题复现两个类，有循环引用： 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 @Data public class Obj1 { private String a; private String b; private O
泛型的类型擦除后fastjson反序列化时如何还原介绍

铺垫在前面的文章中，我们讲过Java中泛型的类型擦除，不过有小伙伴在后台留言提出了一个问题，带有泛型的实体的反序列化过程是如何实
(最新最完整)JDK1.8下载、安装和环境配置超详细教

一、下载安装包 1. JDK1.8百度云下载路径：百度网盘下载链接: https://pan.baidu.com/s/1H54MWN6suutVouYGe5e4og?pwd=tetv 提取码: tetv 网盘放的是jdk1.8版本
Spring Retry 重试实例详解

spring-retry是什么？ spring-retry是spring提供的一个重试框架，原本自己实现的重试机制，现在spring帮封装好提供更加好的编码体验。重试的使用
SpringCloud hystrix断路器与局部降级全面介绍

服务降级服务压力剧增的时候，根据当前的业务情况及流量对一些服务和页面有策略的降级，以此缓解服务器的压力，以保证核心任务的进