首页 - 资讯 - 科技 - 教育 - 汽车 - 财经 - 健康 - 房产 - 文旅 - 娱乐 - 游戏
幼教 |高考 |大学 |就业 |锐评 |培训 |数码 |互联网 |名企 |IT业 |能源 |资讯 |焦点 |会展
当前位置： 首页> 教育> 就业 > 太原网站建设方案报价_pc网站建设建站模板_百度人气榜排名_百度售后服务电话

太原网站建设方案报价_pc网站建设建站模板_百度人气榜排名_百度售后服务电话

时间:2025/7/13 18:59:11来源：https://blog.csdn.net/qq_40926260/article/details/142866650 浏览次数:0次
太原网站建设方案报价_pc网站建设建站模板_百度人气榜排名_百度售后服务电话

文章目录

  • BlockingQueue
  • BlockingDeque
  • TransferQueue
  • ArrayBlockingQueue
  • LinkedBlockingQueue
  • PriorityBlockingQueue
  • DelayQueue
  • SynchronousQueue

BlockingQueue

BlockingQueue 是位于 java.util.concurrent 包中的一个接口，它扩展了 Queue 接口，提供了额外的阻塞特性。BlockingQueue 允许在多线程环境中安全地执行生产者-消费者模式，确保在并发访问时线程安全。

在JDK中有如下实现

在这里插入图片描述

主要特性

  1. 阻塞操作：
    插入元素：当队列已满时，生产者线程会被阻塞，直到有空间可用。
    获取元素：当队列为空时，消费者线程会被阻塞，直到有元素可用。
  2. 线程安全：所有的操作都是线程安全的，保证了多个线程同时访问队列时的数据一致性。

Java 提供了几种 BlockingQueue 的实现，包括：

  1. ArrayBlockingQueue：有界阻塞队列，使用数组实现。在创建时需要指定容量。适合有限的任务处理。
  2. LinkedBlockingQueue：也可以是有界或无界的，使用链表实现。默认情况下，无界队列适合处理大量任务。
  3. PriorityBlockingQueue：支持优先级的无界阻塞队列。需要提供一个比较器来确定元素的优先级。
  4. DelayQueue：支持延迟处理的阻塞队列。适合定时任务的调度。
  5. SynchronousQueue：不持有任何元素的阻塞队列，插入操作必须等待另一个线程进行提取操作。用于实现直接传递任务的场景。

常用方法

  1. void put(E e)：添加元素，如果队列满，线程阻塞直到有空间可用。
  2. boolean offer(E e, long timeout, TimeUnit unit)：在指定时间内尝试添加元素，超时后返回 false。
  3. E take()：提取元素，如果队列为空，线程阻塞直到有元素可用。
  4. E poll(long timeout, TimeUnit unit)：在指定时间内尝试提取元素，超时后返回 null。
  5. int remainingCapacity()：返回队列的剩余容量。
  6. boolean isEmpty()：检查队列是否为空。

BlockingDeque

继承自BlockingQueue，BlockingQueue 的双端队列版本，支持在队列的两端进行插入和提取操作，并且这些操作都是阻塞的。BlockingDeque 的常用实现是LinkedBlockingDeque，它是基于链表的无界双端阻塞队列，JDK 中没有基于数组的实现版本

主要特性

  1. 可以从队列的两端（头部和尾部）插入和提取元素。
  2. 阻塞特性：当队列满时，插入操作会阻塞；当队列为空时，提取操作会阻塞。
  3. 线程安全：所有操作都是线程安全的，适合在多线程环境中使用。

常用方法

  1. void putFirst(E e)：在队列头部插入元素，若队列满则阻塞。
  2. void putLast(E e)：在队列尾部插入元素，若队列满则阻塞。
  3. E takeFirst()：提取并移除队列头部的元素，若队列为空则阻塞。
  4. E takeLast()：提取并移除队列尾部的元素，若队列为空则阻塞。
  5. int remainingCapacity()：返回队列的剩余容量。
  6. boolean isEmpty()：检查队列是否为空。

TransferQueue

TransferQueue 扩展了 BlockingQueue 接口，支持直接转移元素。它主要用于实现生产者-消费者模式中更高效的任务传递。

主要特性

  1. 直接转移：TransferQueue 提供了 transfer 方法，允许生产者在没有消费者准备好接收元素时阻塞并等待。
  2. 非阻塞转移：tryTransfer 方法允许生产者尝试转移元素，如果没有消费者准备好，则返回 false。
  3. 阻塞特性：与 BlockingQueue 类似，当队列满时，插入操作会阻塞；当队列为空时，提取操作会阻塞。

LinkedTransferQueue 是 TransferQueue 的一个常用实现，采用链表结构，允许无界的队列操作，也没有数组实现版本

常用方法

  1. void transfer(E e)：如果没有消费者准备好接收元素，当前线程会阻塞，直到有消费者调用 take 或 poll 方法。
  2. boolean tryTransfer(E e)：尝试转移元素，如果没有消费者准备好，则返回 false。
    标准操作：
  3. void put(E e)：将元素插入队列，如果队列已满则阻塞。
  4. E take()：提取并移除队列头部的元素，如果队列为空则阻塞。
import java.util.concurrent.LinkedTransferQueue;public class TransferQueueExample {public static void main(String[] args) {LinkedTransferQueue<Integer> queue = new LinkedTransferQueue<>();// 生产者线程Thread producer = new Thread(() -> {try {for (int i = 1; i <= 5; i++) {queue.transfer(i); // 直接转移元素System.out.println("Produced: " + i);}} catch (InterruptedException e) {Thread.currentThread().interrupt();}});// 消费者线程Thread consumer = new Thread(() -> {try {for (int i = 1; i <= 5; i++) {int value = queue.take(); // 提取元素System.out.println("Consumed: " + value);}} catch (InterruptedException e) {Thread.currentThread().interrupt();}});producer.start();consumer.start();}
}

ArrayBlockingQueue

ArrayBlockingQueue 使用数组来存储元素，具有固定的大小。数组的索引用于管理队列的头部和尾部。内部使用了 ReentrantLock 和 Condition 来实现阻塞特性。

  1. put 方法会在队列满时调用 Condition 的 await() 方法，阻塞当前线程。
  2. take 方法会在队列为空时调用 Condition 的 await() 方法，阻塞当前线程。

ArrayBlockingQueue 采用循环数组的方式来存储元素，这样可以有效地利用数组空间并减少内存复制。使用头尾两个指针来跟踪队列的头部和尾部位置，确保在插入和提取元素时的高效性。

特性如下：

  1. 容量限制：ArrayBlockingQueue 是有界的，必须在创建时指定容量。如果尝试在队列已满时添加元素，线程将被阻塞。
  2. 线程安全：所有操作都是线程安全的，但在高并发环境下，尽量避免长时间占用队列，避免造成不必要的阻塞。
  3. 阻塞特性：使用 put 和 take 方法时，线程会阻塞。要确保在合适的情况下使用这些方法，以避免死锁或性能问题。
  4. 中断处理：在使用阻塞方法时，应适当地处理 InterruptedException，确保线程可以安全中断。

使用示例：

import java.util.concurrent.ArrayBlockingQueue;public class ArrayBlockingQueueExample {public static void main(String[] args) {ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(5);// 生产者线程Thread producer = new Thread(() -> {try {for (int i = 1; i <= 10; i++) {queue.put(i);System.out.println("Produced: " + i);}} catch (InterruptedException e) {Thread.currentThread().interrupt();}});// 消费者线程Thread consumer = new Thread(() -> {try {for (int i = 1; i <= 10; i++) {int value = queue.take();System.out.println("Consumed: " + value);}} catch (InterruptedException e) {Thread.currentThread().interrupt();}});producer.start();consumer.start();}
}

LinkedBlockingQueue

使用链表实现，可以是有界的或无界的。默认情况下是无界的，除非在创建时指定容量。

PriorityBlockingQueue

支持优先级的无界阻塞队列。需要提供一个比较器来定义元素的优先级。元素的提取顺序是根据优先级而非插入顺序。

PriorityBlockingQueue 基于最小堆（Min-Heap）实现。最小堆是一种完全二叉树，根节点是最小值，任何节点的值都不大于其子节点的值。这种结构使得最小值可以在 O(1) 的时间复杂度内被访问。

自然顺序或自定义比较器：当创建 PriorityBlockingQueue 时，可以传入一个 Comparator，确定元素的优先级。如果没有提供，则元素必须实现 Comparable 接口。

插入和提取操作

  1. offer 和 put 方法：当插入新元素时，PriorityBlockingQueue 会将其插入到堆中，并维护堆的特性，确保最小值（或最大值）始终在根节点。
  2. take 和 poll 方法：take 方法会从队列中提取并移除根节点（优先级最高的元素），并将堆重新调整以恢复堆的特性。这一过程称为“下沉”。
import java.util.concurrent.PriorityBlockingQueue;class Task implements Comparable<Task> {private final int priority;public Task(int priority) {this.priority = priority;}public int getPriority() {return priority;}@Overridepublic int compareTo(Task other) {return Integer.compare(this.priority, other.priority);}@Overridepublic String toString() {return "Task with priority: " + priority;}
}public class PriorityBlockingQueueExample {public static void main(String[] args) {PriorityBlockingQueue<Task> queue = new PriorityBlockingQueue<>();// 添加任务queue.offer(new Task(3));queue.offer(new Task(1));queue.offer(new Task(2));// 提取任务while (!queue.isEmpty()) {Task task = queue.poll();System.out.println("Processing " + task);}}
}

DelayQueue

DelayQueue 是 Java 并发包中的一个阻塞队列，属于 java.util.concurrent 包。它实现了 BlockingQueue 接口，主要用于在一定的延迟后处理元素。DelayQueue 中的元素必须实现 Delayed 接口，这样队列才能根据元素的延迟时间进行排序。

主要特性

  1. 队列中的元素在到达指定的延迟时间之前无法被取出
  2. 元素必须实现 Delayed 接口
  3. 当队列为空时，尝试获取元素的线程会被阻塞，直到有元素可用
  4. 根据元素的延迟时间自动排序，最早到期的元素优先被处理

下面来看一个案例

import java.util.concurrent.DelayQueue;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;class DelayedTask implements Delayed {private final String name;private final long delayTime;private final long startTime; // 任务预期开始执行的时间public DelayedTask(String name, long delayTime) {this.name = name;this.delayTime = delayTime;this.startTime = System.currentTimeMillis() + delayTime;}@Overridepublic long getDelay(TimeUnit unit) {long diff = startTime - System.currentTimeMillis();return unit.convert(diff, TimeUnit.MILLISECONDS);}@Overridepublic int compareTo(Delayed o) {return Long.compare(this.getDelay(TimeUnit.MILLISECONDS), o.getDelay(TimeUnit.MILLISECONDS));}@Overridepublic String toString() {return "Task: " + name + ", Delay: " + delayTime + "ms";}
}public class DelayQueueExample {public static void main(String[] args) {DelayQueue<DelayedTask> delayQueue = new DelayQueue<>();// 添加任务到队列delayQueue.add(new DelayedTask("Task 1", 3000)); // 3秒后delayQueue.add(new DelayedTask("Task 2", 1000)); // 1秒后delayQueue.add(new DelayedTask("Task 3", 2000)); // 2秒后// 处理任务try {while (!delayQueue.isEmpty()) {DelayedTask task = delayQueue.take(); // 阻塞直到有元素System.out.println("Processing " + task);}} catch (InterruptedException e) {Thread.currentThread().interrupt();}}
}

DelayedTask 需要实现 Delayed 接口，定义延迟任务的基本属性和方法。

  1. getDelay：返回到期时间，即剩余的延迟时间
  2. compareTo：用于比较两个延迟任务的到期时间，进行排序

SynchronousQueue

不持有任何元素，每个插入操作必须等待一个提取操作。无法指定容量，因为它不会存储元素

SynchronousQueue 使用了 ReentrantLock 和 Condition 来管理线程之间的同步。
无缓冲区：由于不存储元素，它实际上是一个直接交付的队列，插入和提取操作是通过手动的线程交互进行的。

import java.util.concurrent.SynchronousQueue;public class SynchronousQueueExample {public static void main(String[] args) {SynchronousQueue<Integer> queue = new SynchronousQueue<>();// 生产者线程Thread producer = new Thread(() -> {try {for (int i = 1; i <= 5; i++) {System.out.println("Producing: " + i);queue.put(i); // 直接交付}} catch (InterruptedException e) {Thread.currentThread().interrupt();}});// 消费者线程Thread consumer = new Thread(() -> {try {for (int i = 1; i <= 5; i++) {int value = queue.take(); // 直接接收System.out.println("Consuming: " + value);}} catch (InterruptedException e) {Thread.currentThread().interrupt();}});producer.start();consumer.start();}
}
关键字：太原网站建设方案报价_pc网站建设建站模板_百度人气榜排名_百度售后服务电话

版权声明:

本网仅为发布的内容提供存储空间，不对发表、转载的内容提供任何形式的保证。凡本网注明“来源：XXX网络”的作品，均转载自其它媒体，著作权归作者所有，商业转载请联系作者获得授权，非商业转载请注明出处。

我们尊重并感谢每一位作者，均已注明文章来源和作者。如因作品内容、版权或其它问题，请及时与我们联系，联系邮箱：809451989@qq.com，投稿邮箱：809451989@qq.com

责任编辑：
>> 相关文章
>> 热门图片
如何认识软件开发模型_渠道推广方案_网络销售哪个平台最好_网上营销是做什么的
如何认识软件开发模型_渠道推广方案_网络销售哪个平台最好_网上营销是做什么的
网站查询域名ip解析_乐清疫情最新通告今天_渠道策略的四种方式_站长工具爱站网
网站查询域名ip解析_乐清疫情最新通告今天_渠道策略的四种方式_站长工具爱站网
长春财经学院学费多少_淡水网站建设定制_网站收录申请_seo整站优化方案案例
长春财经学院学费多少_淡水网站建设定制_网站收录申请_seo整站优化方案案例
建立网络平台需要什么_潍坊专业环保设备_seo搜索推广费用多少_网站seo优化的目的
建立网络平台需要什么_潍坊专业环保设备_seo搜索推广费用多少_网站seo优化的目的
漂亮的网页_商务网站规划与设计实训报告_优化方案模板_安全优化大师
漂亮的网页_商务网站规划与设计实训报告_优化方案模板_安全优化大师
联通腾讯合作_seo职位具体做什么_上饶seo博客_厦门seo哪家强
联通腾讯合作_seo职位具体做什么_上饶seo博客_厦门seo哪家强
深圳龙岗网络科技有限公司_沅江网站设计公司_营销方式和渠道_查看关键词被搜索排名的软件
深圳龙岗网络科技有限公司_沅江网站设计公司_营销方式和渠道_查看关键词被搜索排名的软件
济南网站建站_华为企业文化_百度站长工具数据提交_百度爱采购平台登录
济南网站建站_华为企业文化_百度站长工具数据提交_百度爱采购平台登录
>> 热门搜索
评论排行
图片新闻
更多>>
幼儿园项目建设背景_网页开发工具怎么调出来_如何使用免费b站推广网站_百度关键词分析工具
b站视频推广网站2024年_企业邮箱是哪个_百度教育_爱站之家
数据结构--递归和数组
软件开发公司需要什么条件_北京优化推广_郑州seo排名优化_谷歌浏览器网页
点击排行

邮箱：809451989@qq.com 网站地图
未经过本站允许,请勿将本站内容传播或复制