并发之PriorityBlockingQueue简单使用

2024-06-20 03:48

本文主要是介绍并发之PriorityBlockingQueue简单使用,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

PriorityBlockingQueue是一个支持优先级的无界阻塞队列,直到系统资源耗尽。默认情况下元素采用自然顺序升序排列。也可以自定义类实现compareTo()方法来指定元素排序规则,或者初始化PriorityBlockingQueue时,指定构造参数Comparator来对元素进行排序。但需要注意的是不能保证同优先级元素的顺序。PriorityBlockingQueue也是基于最小二叉堆实现,使用基于CAS实现的自旋锁来控制队列的动态扩容,保证了扩容操作不会阻塞take操作的执行

实现类需要自己实现一个继承了 Comparator 接口的类, 在插入资源时会按照自定义的排序规则来对资源数组进行排序。 其中值大的排在数组后面 ,取值时从数组投开始取


/*** 生产者**/
public class ExBean implements Comparable<ExBean> {int id;String name;public String getName() {return name;}public int getId() {return id;}public void setName(String name) {this.name = name;}public void setId(int id) {this.id = id;}public ExBean(int id,String name) {this.name = name;this.id = id;}@Overridepublic int compareTo(ExBean exBean) {return this.id - exBean.getId();}@Overridepublic String toString() {return "ExBean{" +"id=" + id +", name='" + name + '\'' +'}';}
}

PriorityBlockingQueue有四个构造方法:

  1. public PriorityBlockingQueue()
  2. public PriorityBlockingQueue(int initialCapacity)//
    根据initialCapacity来设置队列的初始容量
  3. public PriorityBlockingQueue(int initialCapacity, Comparator<? super
    E> comparator)// 根据initialCapacity来设置队列的初始容量,并根据comparator对象来对数据进行排序
  4. public PriorityBlockingQueue(Collection<? extends E> c)// 根据集合来创建队列

常用的添加元素函数

  1. add():若超出了度列的长度会直接抛出异常:
  2. put():若向队尾添加元素的时候发现队列已经满了会发生阻塞一直等待空间,以加入元素。
  3. offer():如果发现队列已满无法添加的话,会直接返回false。

从队列中取出并移除头元素的方法

  1. poll():若队列为空,返回null。
  2. remove():若队列为空,抛出NoSuchElementException异常。
  3. take():若队列为空,发生阻塞,等待有元素。

返回队列头列表

  1. element():返回队列头元素,如果为空则抛出异常NoSuchEleMentException
  2. peek():返回队列头元素,如果为空则返回null

ExQueueManager.class

public class ExQueueManager {private static ExQueueManager manager;private PriorityBlockingQueue<Object> queue ;private ExQueueManager(){queue = new PriorityBlockingQueue();}public static ExQueueManager getInstance(){if (null==manager){synchronized (ExQueueManager.class){if (null==manager){manager = new ExQueueManager();}}}return manager ;}/*** 添加** @param t* @param <T>*/public <T extends Comparable> void add(T t){queue.add(t);}/*** 取出*/public <T extends Comparable> T take(){try {if (!queue.isEmpty()){return (T) queue.take();}} catch (InterruptedException e) {e.printStackTrace();}return null ;}public boolean isEmpty(){return queue.isEmpty();}}

消费者


/*** 消費者*/
public class ExQueueThread extends Thread {@Overridepublic void run() {super.run();try {while (!ExQueueManager.getInstance().isEmpty()){/*同时取三个 用来消费*/ExBean t = ExQueueManager.getInstance().take();ExBean t1 = ExQueueManager.getInstance().take();ExBean t2 = ExQueueManager.getInstance().take();Thread.sleep(3000);Log.v("tag","[ExBean]->"+t.toString());Log.v("tag","[ExBean]->"+t1.toString());Log.v("tag","[ExBean]->"+t2.toString());}} catch (InterruptedException e) {e.printStackTrace();}}
}

测试结果

    private void initQueue() {for (int i=0;i<10;i++){ExQueueManager.getInstance().add(new ExBean(i,"公司大發噶的風格 i="+i));}new ExQueueThread().start();}

在这里插入图片描述

这篇关于并发之PriorityBlockingQueue简单使用的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1077011

相关文章

Java并发编程必备之Synchronized关键字深入解析

《Java并发编程必备之Synchronized关键字深入解析》本文我们深入探索了Java中的Synchronized关键字,包括其互斥性和可重入性的特性,文章详细介绍了Synchronized的三种... 目录一、前言二、Synchronized关键字2.1 Synchronized的特性1. 互斥2.

使用Sentinel自定义返回和实现区分来源方式

《使用Sentinel自定义返回和实现区分来源方式》:本文主要介绍使用Sentinel自定义返回和实现区分来源方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Sentinel自定义返回和实现区分来源1. 自定义错误返回2. 实现区分来源总结Sentinel自定

Mysql表的简单操作(基本技能)

《Mysql表的简单操作(基本技能)》在数据库中,表的操作主要包括表的创建、查看、修改、删除等,了解如何操作这些表是数据库管理和开发的基本技能,本文给大家介绍Mysql表的简单操作,感兴趣的朋友一起看... 目录3.1 创建表 3.2 查看表结构3.3 修改表3.4 实践案例:修改表在数据库中,表的操作主要

Pandas使用SQLite3实战

《Pandas使用SQLite3实战》本文主要介绍了Pandas使用SQLite3实战,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学... 目录1 环境准备2 从 SQLite3VlfrWQzgt 读取数据到 DataFrame基础用法:读

JSON Web Token在登陆中的使用过程

《JSONWebToken在登陆中的使用过程》:本文主要介绍JSONWebToken在登陆中的使用过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录JWT 介绍微服务架构中的 JWT 使用结合微服务网关的 JWT 验证1. 用户登录,生成 JWT2. 自定义过滤

Java中StopWatch的使用示例详解

《Java中StopWatch的使用示例详解》stopWatch是org.springframework.util包下的一个工具类,使用它可直观的输出代码执行耗时,以及执行时间百分比,这篇文章主要介绍... 目录stopWatch 是org.springframework.util 包下的一个工具类,使用它

Java使用Curator进行ZooKeeper操作的详细教程

《Java使用Curator进行ZooKeeper操作的详细教程》ApacheCurator是一个基于ZooKeeper的Java客户端库,它极大地简化了使用ZooKeeper的开发工作,在分布式系统... 目录1、简述2、核心功能2.1 CuratorFramework2.2 Recipes3、示例实践3

springboot security使用jwt认证方式

《springbootsecurity使用jwt认证方式》:本文主要介绍springbootsecurity使用jwt认证方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录前言代码示例依赖定义mapper定义用户信息的实体beansecurity相关的类提供登录接口测试提供一

go中空接口的具体使用

《go中空接口的具体使用》空接口是一种特殊的接口类型,它不包含任何方法,本文主要介绍了go中空接口的具体使用,具有一定的参考价值,感兴趣的可以了解一下... 目录接口-空接口1. 什么是空接口?2. 如何使用空接口?第一,第二,第三,3. 空接口几个要注意的坑坑1:坑2:坑3:接口-空接口1. 什么是空接

springboot security快速使用示例详解

《springbootsecurity快速使用示例详解》:本文主要介绍springbootsecurity快速使用示例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝... 目录创www.chinasem.cn建spring boot项目生成脚手架配置依赖接口示例代码项目结构启用s